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

Topics (27320)

Replies

Last Post

Views

[jira] [Created] (FLINK-2532) The function name and the variable name are same, it is confusing by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2531) combining the "if" branch to improve the performance by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2530) optimize equal() of AcknowledgeCheckpoint by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2529) fix on some unused code for flink-runtime by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2528) MatchTaskTest failure by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2527) If a VertexUpdateFunction calls setNewVertexValue more than once, the MessagingFunction will only see the first value set by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2526) Add catch{} for task when it stop running by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2525) Add configuration support in Storm-compatibility by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Improve performance of call system.currentTimeMillis() by Fangfengbin

by Stephan Ewen

[jira] [Created] (FLINK-2524) Add "getTaskNameWithSubtasks()" to RuntimeContext by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2523) Increase interrupt timeout in Task Canceling by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Flink Forward webpage down by Gábor Gévay

by Gábor Gévay

[jira] [Created] (FLINK-2522) Integrate Streaming Api into Flink-scala-shell by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2521) Add automatic test name logging for tests by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2520) StreamFaultToleranceTestBase does not allow for multiple tests by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2519) BarrierBuffers get stuck infinitely when some inputs end early by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2518) Avoid predetermination of ports for network services by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2517) Wrong KafkaSink arguments in streaming guide by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2516) Remove unwanted log.isInfoEnabled check by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Builds Problems on Travis by Matthias J. Sax

by Stephan Ewen

[jira] [Created] (FLINK-2515) CheckpointCoordinator triggers checkpoints even if not all sources are running any more by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2514) Local and Remote environment behave differently when re-triggering execution. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[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...

1 ... 700701702703704705706 ... 781