(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 ... 680681682683684685686 ... 781

Topics (27306)

Replies

Last Post

Views

[jira] [Created] (FLINK-3048) DataSinkTaskTest.testCancelDataSinkTask by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3047) Local batch execution: set number of task manager slots to the maximum parallelism by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3046) Integrate the Either Java type with the TypeExtractor by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3045) Properly expose the key of a kafka message by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3044) In YARN mode, configure FsStateBackend by default. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3043) Kafka Connector description in Streaming API guide is wrong/outdated by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3042) Define a way to let types create their own TypeInformation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3041) Twitter Streaming Description section of Streaming Programming guide refers to an incorrect example 'TwitterLocal' by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3040) Add docs describing how to configure State Backends by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3039) Trigger KeyValueState cannot be Scala Int by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Fixing the ExecutionConfig by Stephan Ewen

by Ufuk Celebi-2

Streaming statefull operator with hashmap by Martin Neumann-2

by Stephan Ewen

[jira] [Created] (FLINK-3038) Add maven plugin to ensure our modules define all used dependencies by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3037) Make the behavior of the Kafka consumer configurable if the offsets to restore from are not available by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3036) Gelly's Graph.fromCsvReader method returns wrongly parameterized Graph by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3035) Redis as State Backend by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3034) Redis SInk Connector by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3033) Redis Source Connector by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3032) Flink does not start on Hadoop 2.7.1 (HDP), due to class conflict by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3031) Consistent Shutdown of Streaming Jobs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSSION] Consistent shutdown of streaming jobs by Gyula Fóra-2

by Stephan Ewen

[jira] [Created] (FLINK-3030) Enhance Dashboard to show Execution Attempts by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3029) JobGraph is not connected correctly in webfrontend for streaming job by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3028) Cannot cancel restarting job via web frontend by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3027) Cancel button in Flink job dashboard does not work by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3026) Publish the flink docker container to the docker registry by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Redis connector for Flink by Matthias J. Sax-2

by Matthias J. Sax-2

[jira] [Created] (FLINK-3025) Flink Kafka consumer may get stuck due to Kafka/Zookeeper client bug by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Failing kafka consumer unable to cancel by Gyula Fóra-2

by Stephan Ewen

[jira] [Created] (FLINK-3024) TimestampExtractor Does not Work When returning Long.MIN_VALUE by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3023) Show Flink version + commit id for -SNAPSHOT versions in web frontend by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3022) Broken link 'Working With State' in Fault Tolerance Section of Stream Programming Guide by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3021) Job submission times out due to classloading issue on JobManager by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3020) Local execution: set number of task manager slots to the maximum parallelism by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3019) CLI does not list running/restarting jobs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 680681682683684685686 ... 781