(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 ... 142143144145146147148 ... 778

Topics (27203)

Replies

Last Post

Views

[jira] [Created] (FLINK-18828) Terminate jobmanager process with zero exit code to avoid unexpected restarting by K8s by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18827) The time attribute is lost when constructing a Table via TableEnvironment.from by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18826) Support to emit and encode upsert messages to Kafka by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18825) Support to process CDC message in batch mode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18824) Support serialization for canal-json format by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18823) Support serialization for debezium-json format by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18822) [umbrella] Improve and complete Change Data Capture formats by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18821) Netty client retry mechanism may cause PartitionRequestClientFactory#createPartitionRequestClient to wait infinitely by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18820) SourceOperator should send MAX_WATERMARK to downstream operator when closed by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18819) All the PubSub tests are failing by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18818) HadoopRenameCommitterHDFSTest.testCommitOneFile[Override: false] failed with "java.io.IOException: The stream is closed" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18817) 'Kerberized YARN per-job on Docker test' failed by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18816) Correct API usage in Pyflink Dependency Management page by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18815) AbstractCloseableRegistryTest.testClose unstable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18814) Translate 'Side Outputs' page of 'DataStream API' into Chinese by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18813) Translate 'Local Installation' page of 'Try Flink' into Chinese by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18812) Upgrade StateFun to Flink 1.11.1 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18811) if a disk is damaged, taskmanager should choose another disk for temp dir , rather than throw an IOException, which causes flink job restart over and over again by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18810) Golang remote functions SDK by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Introduce SupportsParallelismReport and SupportsStatisticsReport for Hive and Filesystem by Jingsong Li

by Jingsong Li

[jira] [Created] (FLINK-18809) Update internal aggregate functions to new type system by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18808) Task-level numRecordsOut metric may be underestimated by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18807) FlinkKafkaProducerITCase.testScaleUpAfterScalingDown failed with "Timeout expired after 60000milliseconds while awaiting EndTxn(COMMIT)" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

dev by 牛奶咖啡

by 牛奶咖啡

[Announce] Flink Forward Global Lineup Released by Seth Wiesman-4

by Seth Wiesman-4

[jira] [Created] (FLINK-18806) Taskmanager doesn't start up with error in config by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18805) ConfigDocsGenerator does not handle multiple upper characters properly by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18804) ConfigDocsGenerator should not create files if they contain no options by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18803) JobGraph cannot be GC when submit via RemoteStreamEnvironment in attach mode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18802) Creating an uber jar when packaging flink-avro by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[VOTE] FLIP-36: Support Interactive Programming in Flink by Xuannan Su

by Xuannan Su

[jira] [Created] (FLINK-18801) Add the new document "10 minutes to PyFlink" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] StreamingFileSink: parallelizing active buckets checkpointing? by Paul Bernier

by Till Rohrmann

[jira] [Created] (FLINK-18800) Avro serialization schema doesn't support Kafka key/value serialization by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18799) improve slot allocation to make resource balance among machines. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 142143144145146147148 ... 778