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

[ https://issues.apache.org/jira/browse/FLINK-30434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhengqi Zhang closed FLINK-30434. - Resolution: Not A Problem > The non-null check for transactionalIdPrefix is unnecessary in the

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

[ https://issues.apache.org/jira/browse/FLINK-30434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17648620#comment-17648620 ] Zhengqi Zhang commented on FLINK-30434: --- Sorry, I didn't notice that the non-null check is also

[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] [Updated] (FLINK-30434) The non-null check for transactionalIdPrefix is unnecessary in the KafkaWriter constructor

[ https://issues.apache.org/jira/browse/FLINK-30434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhengqi Zhang updated FLINK-30434: -- Description: The non-null check for transactionalIdPrefix is unnecessary in the KafkaWriter

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

[ https://issues.apache.org/jira/browse/FLINK-27320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638059#comment-17638059 ] Zhengqi Zhang commented on FLINK-27320: --- After many repeated tests, Flink1.16.0 seems to work very

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

[ https://issues.apache.org/jira/browse/FLINK-27320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17637647#comment-17637647 ] Zhengqi Zhang commented on FLINK-27320: --- Which version of kafka server should I test with flink

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

[ https://issues.apache.org/jira/browse/FLINK-27318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17531056#comment-17531056 ] Zhengqi Zhang commented on FLINK-27318: --- I understand the rationale for this part of the code

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

[ https://issues.apache.org/jira/browse/FLINK-27174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17530500#comment-17530500 ] Zhengqi Zhang commented on FLINK-27174: --- [~fpaul], If you think this proposal works, can you give

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

[ https://issues.apache.org/jira/browse/FLINK-27318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17530498#comment-17530498 ] Zhengqi Zhang commented on FLINK-27318: --- This can happen if the task runs for a while and

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

[ https://issues.apache.org/jira/browse/FLINK-27318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhengqi Zhang updated FLINK-27318: -- Attachment: image-2022-05-01-16-50-27-264.png > KafkaSink: when init transaction, it take too

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

[ https://issues.apache.org/jira/browse/FLINK-27320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17529405#comment-17529405 ] Zhengqi Zhang commented on FLINK-27320: --- Kafak Server: kafka_2.13-2.7.0 Flink Version:

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

[ https://issues.apache.org/jira/browse/FLINK-27174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17526356#comment-17526356 ] Zhengqi Zhang edited comment on FLINK-27174 at 4/22/22 11:57 AM: - Yes.

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

[ https://issues.apache.org/jira/browse/FLINK-27174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17526356#comment-17526356 ] Zhengqi Zhang commented on FLINK-27174: --- In the current code, if the user does not use the

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

[ https://issues.apache.org/jira/browse/FLINK-27174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17526313#comment-17526313 ] Zhengqi Zhang commented on FLINK-27174: --- [~fpaul] , please take a look > Non-null check for

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

[ https://issues.apache.org/jira/browse/FLINK-27318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17525568#comment-17525568 ] Zhengqi Zhang commented on FLINK-27318: --- [~arvid]  it take too long to abort previous

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

[ https://issues.apache.org/jira/browse/FLINK-27318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhengqi Zhang updated FLINK-27318: -- Issue Type: Bug (was: Improvement) > KafkaSink: when init transaction, it take too long to

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

[ https://issues.apache.org/jira/browse/FLINK-27318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhengqi Zhang updated FLINK-27318: -- Attachment: image-2022-04-20-17-59-27-397.png Description: as we can see, the new

[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] [Commented] (FLINK-22438) add numRecordsOut metric for Async IO

[ https://issues.apache.org/jira/browse/FLINK-22438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334412#comment-17334412 ] Zhengqi Zhang commented on FLINK-22438: --- Yes,I'll submit a PR later > add numRecordsOut metric

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

[ https://issues.apache.org/jira/browse/FLINK-22438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17332080#comment-17332080 ] Zhengqi Zhang commented on FLINK-22438: --- [~knaufk] In Flink 1.9,there is no problem with AsyncIO's 

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

[ https://issues.apache.org/jira/browse/FLINK-22438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhengqi Zhang updated FLINK-22438: -- Priority: Major (was: Minor) > add numRecordsOut metric for Async IO >

[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:

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

[ https://issues.apache.org/jira/browse/FLINK-22438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhengqi Zhang updated FLINK-22438: -- Attachment: QQ截图20210424004201.png > add numRecordsOut metric for Async IO >

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

[ https://issues.apache.org/jira/browse/FLINK-21690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17298771#comment-17298771 ] Zhengqi Zhang commented on FLINK-21690: --- OK, the I will submit a pull request. > remove redundant

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

[ https://issues.apache.org/jira/browse/FLINK-21690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhengqi Zhang updated FLINK-21690: -- Attachment: image-2021-03-10-18-04-34-353.png > remove redundant

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

[ https://issues.apache.org/jira/browse/FLINK-21690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17298716#comment-17298716 ] Zhengqi Zhang commented on FLINK-21690: --- I mean why the settings are made twice here.

[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

[jira] [Commented] (FLINK-20092) [Java 11] Multi-thread Flink compilation not working

[ https://issues.apache.org/jira/browse/FLINK-20092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17291592#comment-17291592 ] Zhengqi Zhang commented on FLINK-20092: --- The command I'm running is *mvn clean package -DskipTests

[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