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

Topics (27306)

Replies

Last Post

Views

[jira] [Created] (FLINK-5892) Recover job state at the granularity of operator by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5891) ConnectedComponents is broken when object reuse enabled by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5890) GatherSumApply broken when object reuse enabled by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5889) Improving the Flink Python batch API test framework by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5888) ForwardedFields annotation is not generating optimised execution plan in example KMeans job by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5887) Make CheckpointBarrier type immutable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5886) Python API for streaming applications by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5885) Java code snippet instead of scala in documentation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5884) Integrate time indicators for Table API & SQL by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Should we supply a new Iterator instance for Functions with Iterable input(s) like CoGroupFunction ? by Lin Li

by Lin Li

[jira] [Created] (FLINK-5883) Re-adding the Exception-thrown code for ListKeyGroupedIterator when the iterator is requested the second time by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5882) TableFunction (UDTF) should support variable types and variable arguments by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5881) Scalar should support variable types and variable arguments by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

KeyGroupRangeAssignment ? by Ovidiu-Cristian MARC...

by Till Rohrmann

[jira] [Created] (FLINK-5880) Add documentation for object reuse for DataStream API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5879) ExecutionAttemptID should invoke super() in constructor by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5878) Add stream-stream inner join on TableAPI by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5877) Fix Scala snippet in Async I/O API doc by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5876) Mention Scala type fallacies for queryable state client serializers by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5875) Use TypeComparator.hash instead of Object.hashCode() for keying in DataStream API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5874) Reject arrays as keys in DataStream API to avoid inconsistent hashing by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5873) KeyedStream: expose an user defined function for key group assignment by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5872) WebUI shows "(null)" root-exception even without exception by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5871) Enforce uniqueness of pattern names in CEP. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5870) Make handlers aware of their REST URLs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5869) ExecutionGraph use FailoverCoordinator to manage the failover of execution vertexes by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5868) Implement a new RestartStrategy that works for the FailoverRegion. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5867) The implementation of FailoverCoordinator by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5866) The implementation of FailoverRegion. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5865) Throw original exception in RocksDB states by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5864) CEP: fix duplicate output patterns problem. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5863) Unify the serialization of queryable list states in different backends by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5862) When JobManager fails, TaskManagers do not cancel tasks, but attempt to reconnect to the JobManager, and report states of tasks deployed in by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5861) TaskManager's components support updating JobManagerGateway by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5860) Replace all the file creating from java.io.tmpdir with TemporaryFolder by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 579580581582583584585 ... 781