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

Topics (27306)

Replies

Last Post

Views

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

[jira] [Created] (FLINK-2490) Remove unwanted boolean check in function SocketTextStreamFunction.streamFromSocket by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2489) Improve the streaming window join by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2488) Expose attemptNumber in RuntimeContext by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2487) the array has out of bounds by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2486) Remove unwanted null check in removeInstance function by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2485) Handle removal of Java Unsafe in Java9 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Failing Test again by Matthias J. Sax

by Aljoscha Krettek-2

[jira] [Created] (FLINK-2484) BarrierBuffer does not properly clean up temp files by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Tuple by Matthias J. Sax

by Matthias J. Sax

[jira] [Created] (FLINK-2483) Add default branch of switch(scheduleMode) in scheduleForExecution function by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2482) Document sreaming processing guarantees by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2481) Test at least once processing guarantee for streaming by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2480) Improving tests coverage for org.apache.flink.streaming.api by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2479) Refactoring of org.apache.flink.runtime.operators.testutils.TestData class by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2478) The page “FlinkML - Machine Learning for Flink“ https://ci.apache.org/projects/flink/flink-docs-master/libs/ml/ contains a dead link by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2477) Add test for SocketClientSink by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2476) Remove unwanted check null of input1 in ConnectedDataStream by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2475) Rename Flink Client log and out file by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Off-heap memory in Flink? by Slim Baltagi

by Stephan Ewen

[jira] [Created] (FLINK-2474) Occasional failures in PartitionedStateCheckpointingITCase by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

A soft reminder by Andra Lungu

by Stephan Ewen

Failing Test by Matthias J. Sax

by Stephan Ewen

[jira] [Created] (FLINK-2473) Add a timeout to ActorSystem shutdown in the Client by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2472) Make the JobClientActor check periodically if the submitted Job is still running and if the JobManager is still alive by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2471) FileSinkFunction invoke performance optimize by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Renaming log file? by Matthias J. Sax

by mxm

[jira] [Created] (FLINK-2470) Stream Iteration can Hang after some Data by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 701702703704705706707 ... 781