(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 ... 616617618619620621622 ... 791

Topics (27681)

Replies

Last Post

Views

[jira] [Created] (FLINK-5092) Add maven profile with code coverage by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5091) Formalize the AppMaster environment for docker compability by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5090) Expose optionally detailed metrics about network queue lengths by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5089) Introduce Loop functions and Enforce Nesting on Data Streams by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5088) Add option to limit subpartition queue length by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Request for permissions in JIRA by Boris Osipov

by Till Rohrmann

[jira] [Created] (FLINK-5087) Additional steps needed for the Java quickstart guide by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5086) Clean dead snapshot files produced by the tasks failing to acknowledge checkpoints by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Add Sonarqube analysis by Boris Osipov

by Till Rohrmann

Request for edit rights in Jira by limcheehau lim

by limcheehau lim

[jira] [Created] (FLINK-5085) Execute CheckpointCoodinator's state discard calls asynchronously by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5084) Replace Java Table API integration tests by unit tests by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5083) Race condition in Rolling/Bucketing Sink pending files cleanup by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5082) Pull ExecutionService lifecycle management out of the JobManager by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5081) unable to set yarn.maximum-failed-containers with flink one-time YARN setup by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5080) Cassandra connector ignores saveAsync result onSuccess by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5079) Failed to submit job to YARN cluster by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5078) Introduce annotations for classes copied from Calcite by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5077) testStreamTableSink falls unstable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5076) Shutting down TM when shutting down new mini cluster by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5075) Kinesis consumer incorrectly determines shards as newly discovered when tested against Kinesalite by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5074) Implement a RunningJobRegistry based on Zookeeper by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5073) ZooKeeperCompleteCheckpointStore executes blocking delete operation in ZooKeeper client thread by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5072) MetricFetcher Ask Timeout by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5071) YARN: yarn.containers.vcores config not respected when checking for vcores by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5070) Unable to use Scala's BeanProperty with classes by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5069) Pending checkpoint statistics gauge by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5068) YARN HA: Job scheduled before TM is up leading to "Not enough free slots" error by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5067) Make Flink compile with 1.8 Java compiler by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5066) prevent LocalInputChannel#getNextBuffer from de-serialising all events when looking for EndOfPartitionEvent only by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5065) Resource leaks in case of lost checkpoint messages by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5064) Checkpoint messages are not scoped to the leader session ID by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5063) State handles are not properly cleaned up for declined or expired checkpoints by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5062) Ensure that all create threads have a proper name by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

issue assignment (FLINK-5002) by Roman Maier

by Fabian Hueske-2

1 ... 616617618619620621622 ... 791