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

Topics (27320)

Replies

Last Post

Views

[ANNOUNCE] CFP open for ApacheCon North America 2016 by Rich Bowen

by Rich Bowen

[jira] [Created] (FLINK-3080) Cannot union a data stream with a product of itself by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Union a data stream with a product of itself by Vasiliki Kalavri

by Vasiliki Kalavri

[jira] [Created] (FLINK-3079) Add utility for measuring the raw read throughput from a Kafka topic by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3078) JobManager does not shutdown when checkpointed jobs are running by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3077) Add "version" command to CliFrontend for showing the version of the installation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Null Pointer Exception in tests but only in COLLECTION mode by André Petermann

by mxm

[jira] [Created] (FLINK-3076) Display channel exchange mode in the plan visualizer by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

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

1 ... 679680681682683684685 ... 781