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

Topics (27276)

Replies

Last Post

Views

Canceling a Cluster Job from Java by Matthias J. Sax

by Matthias J. Sax

Make docs searchable by Ufuk Celebi-2

by Ufuk Celebi-2

[jira] [Created] (FLINK-1817) ClassLoaderObjectInputStream fails with ClassNotFoundException for primitive classes by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-1816) DegreesWithExceptionITCase.testGetDegreesInvalidEdgeSrcId fails with wrong exception by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-1815) Add methods to read and write a Graph as adjacency list by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-1814) Revisit the documentation to add new operator by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-1813) Barrier broadcast sometimes causes illegal state exception in source RecordWriter by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Gelly iteration abstractions by Vasiliki Kalavri

by Vasiliki Kalavri

[QUESTION] In the DataExchangeMode.BATCH how does the consumer being notified to start consumer the data? by Henry Saputra

by Henry Saputra

[jira] [Created] (FLINK-1812) TaskManager shell scripts restart JVMs on process failures by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-1811) Allow users to pass custom buffer sizes and timeouts to PersistentKafkaSource by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Question about Infinite Streaming Job on Mini Cluster and ITCase by Matthias J. Sax

by Matthias J. Sax

[jira] [Created] (FLINK-1810) UpdateTask message contains unused information by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

A small Project I've been working on by Aljoscha Krettek-2

by mxm

[jira] [Created] (FLINK-1809) Add standard scaler to ML library by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Apache Flink connection with Hbase by santosh_rajaguru

by Stephan Ewen

[jira] [Created] (FLINK-1808) Omit sending checkpoint barriers when the execution graph is not running by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-1807) Stochastic gradient descent optimizer for ML library by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Marking affected and fixed versions in JIRA by Ufuk Celebi-2

by Ufuk Celebi-2

[jira] [Created] (FLINK-1806) Improve S3 file system error message when no access/secret key provided by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Memory segment error by Andra Lungu

by Fabian Hueske-2

[jira] [Created] (FLINK-1805) The class IOManagerAsync(in org.apache.flink.runtime.io.disk.iomanager) should use its own Log by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-1804) flink-quickstart-scala tests fail on scala-2.11 build profile on travis by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-1803) Add type hints to the streaming api by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-1802) BlobManager directories should be checked before TaskManager startup by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-1801) NetworkEnvironment should start without JobManager association by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Add a "Beta" badge in the documentation to components in flink-staging by Robert Metzger

by Robert Metzger

[jira] [Created] (FLINK-1800) Add a "Beta" badge in the documentation to components in flink-staging by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-1799) Scala API does not support generic arrays by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[VOTE] Name of Expression API Representation by Aljoscha Krettek-2

by mxm

Restructuring the maven projects by Stephan Ewen

by Stephan Ewen

[jira] [Created] (FLINK-1798) Bug in IterateExample while running with parallelism > 1: broker slot is already occupied by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-1797) Add jumping pre-reducer for Count and Time windows by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-1796) Local mode TaskManager should have a process reaper by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-1795) Solution set allows duplicates upon construction. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 727728729730731732733 ... 780