[jira] [Created] (FLINK-22887) Backlog based optimizations for RebalancePartitioner and RescalePartitioner

Jiayi Liao created FLINK-22887: -- Summary: Backlog based optimizations for RebalancePartitioner and RescalePartitioner Key: FLINK-22887 URL: https://issues.apache.org/jira/browse/FLINK-22887 Project: Flin

[jira] [Created] (FLINK-22886) Thread leak in RocksDBStateUploader

Jiayi Liao created FLINK-22886: -- Summary: Thread leak in RocksDBStateUploader Key: FLINK-22886 URL: https://issues.apache.org/jira/browse/FLINK-22886 Project: Flink Issue Type: Bug Com

[jira] [Created] (FLINK-22885) Support 'SHOW COLUMNS'.

Roc Marshal created FLINK-22885: --- Summary: Support 'SHOW COLUMNS'. Key: FLINK-22885 URL: https://issues.apache.org/jira/browse/FLINK-22885 Project: Flink Issue Type: Improvement Compo

[DISCUSS] Support specifying custom transactional.id prefix in FlinkKafkaProducer

Hi everyone, Currently, the "transactional.id"s of the Kafka producers in FlinkKafkaProducer are generated based on the task name. This mechanism has some limitations: - It will exceed Kafka's limitation if the task name is too long. (resolved in FLINK-17691) - They will very likely clash with