(DEPRECATED) Apache Flink Mailing List archive.

This used to be a public archive of the Flink mailing mailing list.

We recommend using the official Apache Mailing List Archive: https://lists.apache.org/list.html?dev@flink.apache.org

New Topic

People

1 ... 201202203204205206207 ... 778

Topics (27218)

Replies

Last Post

Views

[jira] [Created] (FLINK-17095) KafkaProducerExactlyOnceITCase fails with "address already in use" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17094) OverWindowITCase#testRowTimeBoundedPartitionedRowsOver failed by FileNotFoundException by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17093) Python UDF doesn't work when the input column is of composite type by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[VOTE] FLIP-113: Supports Dynamic Table Options for Flink SQL by Danny Chan-2

by Benchao Li

[jira] [Created] (FLINK-17092) Pyflink failure for BlinkStreamDependencyTests and StreamPandasUDFITTests by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17091) AvroRowSerializationSchema doesn't support new Timestamp conversion classes by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17090) Harden preckeck for the KubernetesConfigOptions.JOB_MANAGER_CPU by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] FLIP-71 - E2E View support in Flink SQL by Zhenghua Gao

by Zhenghua Gao

[jira] [Created] (FLINK-17089) Checkpoint fail because RocksDBException: Error While opening a file for sequentially reading by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17088) Search TaskManager log content based on keywords function by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17087) Use constant port for rest.port when it's set as 0 on Kubernetes by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17086) Flink sql client not able to read parquet hive table because `HiveMapredSplitReader` not supports name mapping reading for parquet format. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17085) Remove FlinkKubeClient#handleException since it does not do anything by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17084) Implement type inference for ROW/ARRAY/MAP constructors by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17083) Restrict users of accumulators not to return null in Accumulator#getLocalValue by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17082) Remove mocking from SQL client tests by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] FLIP-105: Support to Interpret and Emit Changelog in Flink SQL by Jark Wu-2

by Jark Wu-2

[jira] [Created] (FLINK-17081) Batch test classes in Blink planner does not extend TestLogger by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17080) Utils.CollectHelper is possible to throw NPE if the sink is up but not initialized when the job fails by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17079) CsvTableSinkFactoryBase add numFiles and writeMode config when createTableSink by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17078) Logging output is misleading when executing bin/flink -e kubernetes-session without specifying cluster-id by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17077) FLINK_CONF_DIR environment variable to locate flink-conf.yaml in Docker container by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17076) Revamp Kafka Connector Documentation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17075) Add task status reconciliation between TM and JM by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Configuring autolinks to Flink JIRA ticket in github repos by Yun Tang

by Till Rohrmann

[DISCUSS] FLIP-111: Docker image unification by Andrey Zagrebin-4

by Ismaël Mejía

[jira] [Created] (FLINK-17074) Deprecate DataStream.keyBy() that use tuple/expression keys by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17073) Slow checkpoint cleanup causing OOMs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17072) Let Dispatcher and ResourceManager pick random endpoint id by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

contributor apply by zhangzhanhua

by Timo Walther-2

[ANNOUNCE] Apache Flink Stateful Functions 2.0.0 released by Tzu-Li (Gordon) Tai

by Zhijiang(wangzhijian...

[jira] [Created] (FLINK-17071) Kubernetes session CLI logging output is either misleading or concerning by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17070) Kubernetes session CLI ignores stop/help command in detached mode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17069) DefaultClusterClientServiceLoader should provide more information in case of missing dependencies by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17068) ERROR at teardown of TableConfigTests.test_get_set_decimal_context by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 201202203204205206207 ... 778