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

Topics (27278)

Replies

Last Post

Views

[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

[jira] [Created] (FLINK-5061) Remove ContinuousEventTimeTrigger by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5060) only serialise records once in RecordWriter#emit and RecordWriter#broadcastEmit by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5059) only serialise events once in RecordWriter#broadcastEvent by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5058) taskManagerMemory attribute set wrong value in FlinkShell by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Flink 4108 and 4061 by Alberto Ramón

by Alberto Ramón

[jira] [Created] (FLINK-5057) Cancellation timeouts are picked from wrong config by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

RocksDB IO error by zhenhao.li

by Aljoscha Krettek-2

[FLINK-3848] Add ProjectableTableSource by Anton Solovev

by Anton Solovev

[jira] [Created] (FLINK-5056) BucketingSink deletes valid data when checkpoint notification is slow. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5055) Security feature crashes JM for certain Hadoop versions even though using no Kerberos by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5054) Make the BucketingSink rescalable. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5053) Incremental / lightweight snapshots for checkpoints by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5052) Changing the maximum parallelism (number of key groups) of a job by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5051) Backwards compatibility for serializers in backend state by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[FLINK-4541] Support for SQL NOT IN operator by Alexander Shoshin

by Alexander Shoshin

[jira] [Created] (FLINK-5050) JSON.org license is CatX by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Releasing Flink 1.1.4 by Ufuk Celebi-2

by Ufuk Celebi-2

[jira] [Created] (FLINK-5049) Instability in QueryableStateITCase.testQueryableStateWithTaskManagerFailure by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 605606607608609610611 ... 780