(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 ... 452453454455456457458 ... 783

Topics (27402)

Replies

Last Post

Views

[ANNOUNCE] Weekly community update #29 by Till Rohrmann

by Till Rohrmann

Flink WindowedStream - Need assistance by Titus Rakkesh

by Timo Walther-2

[jira] [Created] (FLINK-9873) Log actual state when aborting checkpoint due to task not running by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9872) SavepointITCase#testSavepointForJobWithIteration does not properly cancell jobs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9871) Use Description class for ConfigOptions with rich formatting by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9870) Support field mapping and time attributes for table sinks by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9869) Send PartitionInfo in batch to Improve perfornance by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9868) Expose channel id to ProcessFunction by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9867) Extend release notes for Flink 1.6 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9866) Allow passing program arguments to StandaloneJobCluster by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9865) flink-hadoop-compatibility should assume Hadoop as provided by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9864) Make timestamp extraction more flexible in SQL Client by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9863) Add a built-in ingestion time TS extractor by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9862) Update end-to-end test to use RocksDB backed timers by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9861) Add end-to-end test for reworked BucketingSink by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9860) Netty resource leak on receiver side by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9859) Distinguish TM akka config with JM config by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9857) Processing-time timers fire too early by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9858) State TTL End-to-End Test by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9856) ExecutionGraphCoLocationRestartTest#testConstraintsAfterRestart failed on travis by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Flink Query Optimizer by albertjonathan

by Piotr Nowojski

[jira] [Created] (FLINK-9855) KeyedStream.IntervalJoined#process does not work for lambdas by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9854) Allow passing multi-line input to SQL Client CLI by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9853) add hex support in table api and sql by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9852) Expose descriptor-based sink creation in table environments by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9851) Add documentation for unified table sources/sinks by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9850) Add a string to the print method to identify output for DataStream by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9849) Upgrade hbase version to 2.0.1 for hbase connector by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[ANNOUNCE] Apache Flink 1.5.1 released by Chesnay Schepler-3

by Yaz Sh

[VOTE] Release 1.5.1, release candidate #3 by Chesnay Schepler-3

by Yaz Sh

[jira] [Created] (FLINK-9848) When Parallelism more than available task slots Flink stays idle by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9847) OneInputStreamTaskTest.testWatermarksNotForwardedWithinChainWhenIdle unstable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9846) Add a Kafka table sink factory by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9845) Make InternalTimerService's timer processing interruptible/abortable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9844) PackagedProgram does not close URLClassLoader by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 452453454455456457458 ... 783