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

Topics (27276)

Replies

Last Post

Views

Re: [jira] [Commented] (FLINK-1106) Deprecate old Record API by Fabian Hueske-2

by aalexandrov

[DISCUSS] Deprecate Spargel API for 0.9 by Vasiliki Kalavri

by Vasiliki Kalavri

[jira] [Created] (FLINK-1691) Inprove CountCollectITCase by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-1690) ProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailure spuriously fails on Travis by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-1689) Add documentation on streaming file sinks interaction with the batch outputformat by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

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

1 ... 732733734735736737738 ... 780