[jira] [Created] (FLINK-20047) DefaultLeaderRetrievalService should only notify the LeaderRetrievalListener when leader truly changed

Yang Wang created FLINK-20047: - Summary: DefaultLeaderRetrievalService should only notify the LeaderRetrievalListener when leader truly changed Key: FLINK-20047 URL: https://issues.apache.org/jira/browse/FLINK-20047

[jira] [Created] (FLINK-20046) StreamTableAggregateTests.test_map_view_iterate is instable

Dian Fu created FLINK-20046: --- Summary: StreamTableAggregateTests.test_map_view_iterate is instable Key: FLINK-20046 URL: https://issues.apache.org/jira/browse/FLINK-20046 Project: Flink Issue Type

[jira] [Created] (FLINK-20045) ZooKeeperLeaderElectionTest.testZooKeeperLeaderElectionRetrieval failed with "TimeoutException: Contender was not elected as the leader within 200000ms"

Dian Fu created FLINK-20045: --- Summary: ZooKeeperLeaderElectionTest.testZooKeeperLeaderElectionRetrieval failed with "TimeoutException: Contender was not elected as the leader within 20ms" Key: FLINK-20045 URL: http

[jira] [Created] (FLINK-20044) Disposal of RocksDB could last forever

Jiayi Liao created FLINK-20044: -- Summary: Disposal of RocksDB could last forever Key: FLINK-20044 URL: https://issues.apache.org/jira/browse/FLINK-20044 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-20043) Add flink-sql-connector-kinesis package

Alexander Alexandrov created FLINK-20043: Summary: Add flink-sql-connector-kinesis package Key: FLINK-20043 URL: https://issues.apache.org/jira/browse/FLINK-20043 Project: Flink Issue

[jira] [Created] (FLINK-20042) Add end-to-end tests for Kinesis Table sources and sinks

Alexander Alexandrov created FLINK-20042: Summary: Add end-to-end tests for Kinesis Table sources and sinks Key: FLINK-20042 URL: https://issues.apache.org/jira/browse/FLINK-20042 Project: Flin