[jira] [Created] (FLINK-30434) The non-null check for transactionalIdPrefix is unnecessary in the KafkaWriter constructor

Zhengqi Zhang created FLINK-30434: - Summary: The non-null check for transactionalIdPrefix is unnecessary in the KafkaWriter constructor Key: FLINK-30434 URL: https://issues.apache.org/jira/browse/FLINK-30434

[jira] [Created] (FLINK-27320) When using KafkaSink EXACTLY_ONCE semantics, frequent OutOfOrderSequenceException anomalies

Zhengqi Zhang created FLINK-27320: - Summary: When using KafkaSink EXACTLY_ONCE semantics, frequent OutOfOrderSequenceException anomalies Key: FLINK-27320 URL: https://issues.apache.org/jira/browse/FLINK-27320

[jira] [Created] (FLINK-27318) KafkaSink: when init transaction, it take too long to get a producerId with epoch=0

Zhengqi Zhang created FLINK-27318: - Summary: KafkaSink: when init transaction, it take too long to get a producerId with epoch=0 Key: FLINK-27318 URL: https://issues.apache.org/jira/browse/FLINK-27318

[jira] [Created] (FLINK-27174) Non-null check for bootstrapServers field is incorrect in KafkaSink

Zhengqi Zhang created FLINK-27174: - Summary: Non-null check for bootstrapServers field is incorrect in KafkaSink Key: FLINK-27174 URL: https://issues.apache.org/jira/browse/FLINK-27174 Project: Flink

[jira] [Created] (FLINK-22438) add numRecordsOut metric for Async IO

Zhengqi Zhang created FLINK-22438: - Summary: add numRecordsOut metric for Async IO Key: FLINK-22438 URL: https://issues.apache.org/jira/browse/FLINK-22438 Project: Flink Issue Type: Improveme

[jira] [Created] (FLINK-21690) remove redundant tolerableCheckpointFailureNumber setting in CheckpointConfig

Zhengqi Zhang created FLINK-21690: - Summary: remove redundant tolerableCheckpointFailureNumber setting in CheckpointConfig Key: FLINK-21690 URL: https://issues.apache.org/jira/browse/FLINK-21690 Proje

[jira] [Created] (FLINK-21499) maven package hang when using multithread on jdk 11

Zhengqi Zhang created FLINK-21499: - Summary: maven package hang when using multithread on jdk 11 Key: FLINK-21499 URL: https://issues.apache.org/jira/browse/FLINK-21499 Project: Flink Issue T