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

Topics (27475)

Replies

Last Post

Views

[jira] [Created] (FLINK-2727) Add a base class for MessageQueue-with-acknowledgement sources by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2726) Harmonise Yarn configuration methods to use a single configuration for all components by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

EventTime in streaming by Martin Neumann-2

by Aljoscha Krettek-2

[jira] [Created] (FLINK-2725) Max/Min/Sum Aggregation of mutable types by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2724) Object reuse not respected in GroupReduceCombineDriver and ReduceCombineDriver by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2723) CopyableValue method to copy into new instance by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2722) Use InetAddress.getLocalHost() first when detecting TaskManager IP address by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2721) Add Tuple meta information by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Some questions about storm metrics by huangwei (G)

by huangwei (G)

[jira] [Created] (FLINK-2720) Add Storm-CountMetric in flink-stormcompatibility by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2719) ProcessFailureStreamingRecoveryITCase>AbstractProcessFailureRecoveryTest.testTaskManagerProcessFailure failed on Travis by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2718) LeaserChangeCleanupTest sometimes fails by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2717) CombineTaskTest sometimes fails by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Tests - Unit Tests versus Integration Tests by Stephan Ewen

by Matthias J. Sax-2

[jira] [Created] (FLINK-2716) Checksum method for DataSet and Graph by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2715) Benchmark Triangle Count methods by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2714) Port the Flink DataSet Triangle Count example to the Gelly library by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2713) Custom StateCheckpointers should be included in the snapshots by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Tests in the streaming API by Stephan Ewen

by Aljoscha Krettek-2

[jira] [Created] (FLINK-2712) Add some description about tests to "How to Contribute" documentation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2711) TaskManagerTest failure by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2710) SocketTextStreamFunctionTest failure by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2709) line editing in scala shell by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2708) Potential null pointer dereference in JoinWithSolutionSetFirstDriver#run() by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2707) Set state checkpointer before default state for PartitionedStreamOperatorState by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2706) Add support for streaming RollingFileSink to truncate / append on UNIX file systems by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2705) Yarn fails with NoSuchMethodError when log level is set to DEBUG by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Flink ML linear regression issue by hanan meyer

by Alexey Sapozhnikov

[jira] [Created] (FLINK-2704) Clean up naming of State/Checkpoint Interfaces by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2703) Remove log4j classes from fat jar / document how to use Flink with logback by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2702) Add an implementation of distributed copying utility using Flink by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2701) Getter for wrapped Java StreamExecutionEnvironment in the Scala Api by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2700) YarnSessionFIFOITCase.testJavaApi failure by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Java type erasure and object reuse by Greg Hogan

by Stephan Ewen

[jira] [Created] (FLINK-2699) Flink is filling Spark JIRA with incorrect PR links by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 697698699700701702703 ... 785