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

Topics (27473)

Replies

Last Post

Views

[ANNOUNCE] Distributed stream and graph processing with Apache Flink Bay Area meetup by Henry Saputra

by Henry Saputra

[jira] [Created] (FLINK-2407) Add an API switch to select between "exactly once" and "at least once" fault tolerance by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2406) Abstract BarrierBuffer to an exchangeable BarrierHandler by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Extending the streaming scala api with stateful functions by Gyula Fóra-2

by Gyula Fóra

[jira] [Created] (FLINK-2405) Add stateful transformations using lambdas to the Streaming Scala API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2404) LongCounters should have an "addValue()" method for primitive longs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2403) Rework partitioned state checkpointing logic by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Any planning for Apache Flink 1.0 release? by Slim Baltagi

by Fabian Hueske-2

[jira] [Created] (FLINK-2402) Add a non-blocking BarrierTracker by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2401) Replace ActorRefs with ActorGateway in web server by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2400) TaskTest.testExecutionFailesAfterCanceling fails by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2399) Fail when actor versions don't match by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Thoughts About Streaming by Aljoscha Krettek-2

by Aljoscha Krettek-2

[jira] [Created] (FLINK-2398) Decouple StreamGraph Building from the API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2397) Unify two backend servers to one server by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Erroneous link to "Flink on Windows" guide by Samia Khalid

by Till Rohrmann

[jira] [Created] (FLINK-2396) Review the datasets of dynamic path and static path in iteration. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2395) Check Scala catch blocks for Throwable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Benchmarks of Flink, supporting Flink in BigDataBench by Xinhui Tian

by hawin

Windowing Design Document by Aljoscha Krettek-2

by Aljoscha Krettek-2

[jira] [Created] (FLINK-2394) HadoopOutFormat OutputCommitter is default to FileOutputCommiter by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2393) Add a "stateless at-least-once" mode for streaming by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2392) Instable test in flink-yarn-tests by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

serialization issue by Felix Neutatz

by Stephan Ewen

Theoretical complexity of a coGroup by Andra Lungu

by Kostas Tzoumas-2

[jira] [Created] (FLINK-2391) Storm-compatibility:method FlinkTopologyBuilder.createTopology() throws java.lang.NullPointerException by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2390) Replace iteration timeout with algorithm for detecting termination by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2389) Add dashboard frontend architecture amd build infrastructue by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2388) JobManager should try retrieving jobs from archive by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2387) Add test for live accumulators in Streaming by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2386) Implement Kafka connector using the new Kafka Consumer API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2385) Scala DataSet.distinct should have parenthesis by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2384) Deadlock during partition spilling by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Communicating between nodes at runtime by Sachin Goel

by Sachin Goel

Failing tests on Windows by Gábor Gévay

by Stephan Ewen

1 ... 709710711712713714715 ... 785