(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 (27320)

Replies

Last Post

Views

[jira] [Created] (FLINK-1699) Co-task sometimes returns null by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-1698) Add polynomial base feature mapper to ML library by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-1697) Add alternating least squares algorithm to ML library by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-1696) Add multiple linear regression to ML library by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-1695) Create machine learning library by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-1694) Change the split between create/run of a vertex-centric iteration by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-1693) Deprecate the Spargel API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Re: [jira] [Commented] (FLINK-1679) Document how "degree of parallelism" / "parallelism" / "slots" are connected to each other by Fabian Hueske-2

by Stephan Ewen

[jira] [Created] (FLINK-1692) Add option to Flink YARN client to stop a detached YARN session. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

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

1 ... 733734735736737738739 ... 781