(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 (27320)

Replies

Last Post

Views

[jira] [Created] (FLINK-3057) Provide a way to pass informaiton back to the plan by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3056) Show bytes sent/received as MBs/GB and so on in web interface by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3055) ExecutionVertex has duplicate method getParallelSubtaskIndex and getSubTaskIndex by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

How to modify TestBaseUtils.TASK_MANAGER_MEMORY_SIZE by André Petermann

by Till Rohrmann

[jira] [Created] (FLINK-3054) Remove R (return) type variable from SerializationSchema by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3053) SuccessAfterNetworkBuffersFailureITCase.testSuccessfulProgramAfterFailure by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3052) Optimizer does not push properties out of bulk iterations by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

SETUP ISSUES by JOHN MILLER

by Martin Junghanns

[jira] [Created] (FLINK-3051) Define a maximum number of concurrent inflight checkpoints by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

How to use static data with streams? by Kashmar, Ali

by Robert Metzger

[DISCUSSION] Type hints versus TypeInfoParser by Stephan Ewen

by Stephan Ewen

[jira] [Created] (FLINK-3050) Add custom Exception type to suppress job restarts by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3049) Move "Either" type to package "org.apache.flink.types" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Add BigDecimal and BigInteger as types by Timo Walther-2

by Stephan Ewen

[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

1 ... 680681682683684685686 ... 781