(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 ... 678679680681682683684 ... 780

Topics (27277)

Replies

Last Post

Views

Either left() vs left(value) by Gyula Fóra

by Gyula Fóra

[jira] [Created] (FLINK-3075) Rename Either creation methods to avoid name clash with projection methods by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

withParameters() for Streaming API by Timo Walther-2

by Chesnay Schepler-2

[jira] [Created] (FLINK-3074) Make ApplicationMaster/JobManager akka port configurable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3073) Activate streaming mode by default by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3072) DbStateBackendTest by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Flink Master on Travis by Matthias J. Sax-2

by Robert Metzger

[DISCUSS] Include import statements in documentation code examples by Robert Metzger

by mxm

[jira] [Created] (FLINK-3071) Add asynchronous materialization thread by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3070) Create an asynchronous state handle interface by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3069) Make state materialization asynchronous by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3068) Add a Table API configuration to TableEnvironment by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Slinding Window Join (without duplicates) by Matthias J. Sax-2

by Stephan Ewen

[jira] [Created] (FLINK-3067) Kafka source fails during checkpoint notifications with NPE by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3066) Kafka source fails on leader change by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3065) Can't cancel failing jobs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3064) Missing size check in GroupReduceOperatorBase leads to NPE by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3063) [py] Remove combiner by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3062) Kafka Producer is not failing if broker is not available/no partitions available by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3061) Kafka Consumer is not failing if broker is not available by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3060) Add possibility to integrate custom types into the TypeExtractor by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Re: ReduceByKeyAndWindow in Flink by Gyula Fóra-2

by Stephan Ewen

[DISCUSS] Release Flink 0.10.1 soon by Robert Metzger

by Robert Metzger

how to write dataset in a file? by jun aoki

by jun aoki

[jira] [Created] (FLINK-3059) Javadoc fix for DataSet.writeAsText() by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3058) Add Kafka consumer for new 0.9.0.0 Kafka API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Fwd: Re: Storm Compatibility by Matthias J. Sax-2

by mxm

[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

1 ... 678679680681682683684 ... 780