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

Topics (27278)

Replies

Last Post

Views

[jira] [Created] (FLINK-5958) Asyncronous snapshots for heap-based keyed state backends by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5957) Remove `getAccumulatorType` method from `AggregateFunction` by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5956) Add retract method into the aggregateFunction by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

回复：Dataset and eager scheduling by wangzhijiang

by wangzhijiang

[jira] [Created] (FLINK-5955) Merging a list of buffered records will have problem when ObjectReuse is turned on by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Gelly planning for release 1.3 and roadmap by Vasiliki Kalavri

by xingcanc

[jira] [Created] (FLINK-5954) Always assign names to the window in the Stream SQL APi by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

About the ACL of Zookeeper by Zhangrucong

by Vijay Srinivasaragha...

[jira] [Created] (FLINK-5953) Sample Kinesis Scala code doesn't work by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Dataset and eager scheduling by CPC

by CPC

[jira] [Created] (FLINK-5952) JobCancellationWithSavepointHandlersTest uses deprecated JsonNode#getValuesAsText by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5951) Register legacy windowOp timers with timer service in the restoreState(). by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5950) create an example for async-io with an http client by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5949) Flink on YARN checks for Kerberos credentials for non-Kerberos authentication methods by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[Dev] Issue related to using Flink DataSet<T> methods by Pawan Manishka Gunar...

by Pawan Manishka Gunar...

Visualizing topologies by Ken Krugler

by Ken Krugler

[jira] [Created] (FLINK-5948) Error in Python zip_with_index documentation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5947) NullPointerException in ContinuousProcessingTimeTrigger.clear() by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5946) Kinesis Producer uses KPL that orphans threads that consume 100% CPU by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5945) Close function in OuterJoinOperatorBase#executeOnCollections by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5944) Flink should support reading Snappy Files by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5943) Unprotected access to haServices in YarnFlinkApplicationMasterRunner#shutdown() by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5942) Harden ZooKeeperStateHandleStore to deal with corrupted data by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5941) Let handlers take part in job archiving by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5940) ZooKeeperCompletedCheckpointStore cannot handle broken state handles by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5939) Wrong version in README.md for several Apache Flink extensions by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5938) Replace ExecutionContext by Executor in Scheduler by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Per-key event time by Jamie Grier

by Jamie Grier

[jira] [Created] (FLINK-5937) Add documentation about the task lifecycle. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5936) Can't pass keyed vectors to KNN join algorithm by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5935) confusing/misleading error message when failing to restore savepoint by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5934) Scheduler in ExecutionGraph null if failure happens in ExecutionGraph.restoreLatestCheckpointedState by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5933) Allow Evictor for merging windows by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5932) Order of legacy vs new state initialization in the AbstractStreamOperator. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5931) Make Flink highly available even if defaultFS is unavailable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 576577578579580581582 ... 780