(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 ... 694695696697698699700 ... 780

Topics (27276)

Replies

Last Post

Views

[jira] [Created] (FLINK-2648) CombineTaskTest.testCancelCombineTaskSorting by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2647) Stream operators need to differentiate between close() and dispose() by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2646) Rich functions should provide a method "closeAfterFailure()" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2645) Accumulator exceptions are not properly forwarded by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2644) State partitioning does not respect the different partitioning of multiple inputs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2643) Change Travis Build Profile to Exclude Hadoop 2.0.0-alpha, Include 2.7.0 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2642) Scala Table API crashes when executing word count example by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

look for help about task hooks of storm-compatibility by Fangfengbin

by Stephan Ewen

[jira] [Created] (FLINK-2641) Integrate the off-heap memory configuration with the TaskManager start script by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2640) Integrate the off-heap configurations with YARN runner by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2639) Building Flink for specific HDP versions fails by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2638) Add @SafeVarargs to the environment.fromElements(...) method by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2637) Add abstract equals, hashCode and toString methods to TypeInformation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2636) Clean up StreamRecord and Watermark types by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2635) Unify StreamInputProcessor and OneInputStreamTask by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2634) Add a Vertex-centric Version of the Tringle Count Library Method by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2633) OptionTypeInfo does not have proper equals and hashCode method by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Volunteers needed for Flink Forward 2015 (and they get a free ticket) by Kostas Tzoumas-2

by Kostas Tzoumas-2

[jira] [Created] (FLINK-2632) Web Client does not respect the class loader of submitted jobs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2631) StreamFold operator does not respect returns type and stores non serializable values by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2630) Scala DataStream API does not have a project method by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2629) Refactor YARN ApplicationMasterActor to use the async AM<-->RM client by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Failing Test: KafkaITCase and KafkaProducerITCase by Matthias J. Sax-2

by Stephan Ewen

Need help with CI problem by huangwei (G)

by huangwei (G)

[jira] [Created] (FLINK-2628) Failing Test: StreamFaultToleranceTestBase.runCheckpointedProgram by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Interested in implementing Machine learning Libraries as my undergraduate final project by Devang Gupta

by till.rohrmann

[jira] [Created] (FLINK-2627) Make Scala Data Set utils easier to access by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Scala Utils by Sachin Goel

by Sachin Goel

[jira] [Created] (FLINK-2626) Add a AverageAccumulator for FLINK-Accumulator by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2625) Configuration not passed to JobGraphGenerator by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Updating the flink JAR with a single module by Niklas Semmler-2

by Niklas Semmler-2

[jira] [Created] (FLINK-2624) RabbitMQ source / sink should participate in checkpointing by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2623) Extend API completeness check to check signatures by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2622) Scala DataStream API does not have writeAsText method which supports WriteMode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-2621) Add support for positional arguments to ParameterTool by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 694695696697698699700 ... 780