(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 ... 705706707708709710711 ... 785

Topics (27473)

Replies

Last Post

Views

[jira] [Created] (FLINK-2513) Extend state handle provider interface to list all state handles by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

nightly builds by Pieter-Jan Van Aeken

by Fabian Hueske-2

Multiple control flows in a program by Sachin Goel

by Till Rohrmann

[jira] [Created] (FLINK-2512) Add client.close() before throw RuntimeException by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2511) Potential resource leak due to unclosed InputStream in FlinkZooKeeperQuorumPeer.java by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2510) KafkaConnector should access partition metadata from master/cluster by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2509) Improve error messages when user code classes are not found by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2508) Confusing sharing of StreamExecutionEnvironment by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

On some GUI tools for building Flink Streaming data flows... by Slim Baltagi

by Stephan Ewen

netty channel for data transfer by wangzhijiang

by Stephan Ewen

[jira] [Created] (FLINK-2507) Rename the function tansformAndEmit in org.apache.flink.stormcompatibility.wrappers.AbstractStormCollector by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

New Flink Runtime Monitor Dashboard by Stephan Ewen

by mxm

[jira] [Created] (FLINK-2506) HBase table that is distributed over more than 1 region server by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2505) HDFSTest failure: VM crash by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Parameter Server for Flink by Sachin Goel

by Sachin Goel

Failing test in Gelly by Matthias J. Sax

by Stephan Ewen

[jira] [Created] (FLINK-2504) ExternalSortLargeRecordsITCase.testSortWithLongAndShortRecordsMixed failed spuriously by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2503) Inconsistencies in FileInputFormat hierarchy by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Cannot run WordCountExample in Intellij by Matthias J. Sax

by Matthias J. Sax

[jira] [Created] (FLINK-2502) FiniteStormSpout documenation does not render correclty by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2501) [py] Remove the need to specify types for transformations by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2500) Some reviews to improve code quality by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2499) start-cluster.sh can start multiple TaskManager on the same node by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2498) GroupReduceITCase failure by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2497) Rework streaming iteration flow control by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[ANNOUNCE] Apache Mahout 0.11.0 Release by Andrew Palumbo

by Andrew Palumbo

[jira] [Created] (FLINK-2496) Expose Task Manager configuration to Runtime Context by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2495) Add a null point check in API DataStream.union by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2494) Fix StreamGraph getJobGraph bug by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[ANNOUNCE] Apache Mahout 0.10.2 Release by Suneel Marthi-2

by Suneel Marthi-2

[jira] [Created] (FLINK-2493) Simplify names of example program JARs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

New failing Kafka Test by Matthias J. Sax

by Stephan Ewen

[jira] [Created] (FLINK-2492) Rename remaining runtime classes from "match" to "join" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

FYI: Blog Post on Flink's Streaming Performance and Fault Tolerance by Stephan Ewen

by Stephan Ewen

[jira] [Created] (FLINK-2491) Operators are not participating in state checkpointing in some cases by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 705706707708709710711 ... 785