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

Topics (27306)

Replies

Last Post

Views

[jira] [Created] (FLINK-1688) Add socket sink by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-1687) Streaming file source API is not in sync with the batch API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-1686) Streaming iteration heads cannot be instantiated by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-1685) Document how to read gzip/compressed files with Flink by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-1684) Make Kafka connectors read/write a partition the worker is on by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Inconsistent git master by Gyula Fóra-2

by Gyula Fóra-2

[gelly] Tests fail, but build succeeds by Stephan Ewen

by Andra Lungu

[jira] [Created] (FLINK-1683) Scheduling preferences for non-unary tasks are not correctly computed by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-1682) Port Record-API based optimizer tests to new Java API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-1681) Remove the old Record API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-1680) Upgrade Flink dependencies for Tachyon to 0.6.0 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-1679) Document how "degree of parallelism" / "parallelism" / "slots" are connected to each other by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-1678) Extend internals documentation: program flow, optimizer, ... by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Add method for each Akka message by Ufuk Celebi-2

by Henry Saputra

[jira] [Created] (FLINK-1677) Properly Suppress Sysout Printing for the Degrees with exception test suite by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-1676) enableForceKryo() is not working as expected by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-1675) Rework Accumulators by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Streaming Fault Tolerance by Stephan Ewen

by Stephan Ewen

[jira] [Created] (FLINK-1674) Add test with nested avro type by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-1673) Colocate Flink Kafka consumer by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-1672) Refactor task registration/unregistration by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-1671) Add execution modes for programs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-1670) Collect method for streaming by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-1669) Streaming tests for recovery with distributed process failure by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-1668) Add a config option to specify delays between restarts by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-1667) Add tests for recovery with distributed process failure by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-1666) Clean-up Field Expression Code by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-1665) Add optional annotations for POJOs to specify the order of fields by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-1664) Fix sorting on POJO fields by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-1663) Add a FIFO job scheduler to the JobManager by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-1662) NullFieldException is thrown when testing IterativeDataStream with tuples, windowing and maxBy by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Documentation Java/Scala order by Hermann Gábor

by mxm

NullFieldException is thrown when testing IterativeDataStream with tuples and maxBy by Szabó Péter

by Márton Balassi

Semantic Properties and Functions with Iterables by Timo Walther-2

by Stephan Ewen

[jira] [Created] (FLINK-1661) No Documentation for the isWeaklyConnected() Method by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 733734735736737738739 ... 781