[
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
[
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
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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:
[
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.
[
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
[
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
[
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
[
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
[
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
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
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
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
[
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
[
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
[
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
>
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:
[
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
>
[
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
[
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
[
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.
Zhengqi Zhang created FLINK-21690:
-
Summary: remove redundant tolerableCheckpointFailureNumber setting
in CheckpointConfig
Key: FLINK-21690
URL: https://issues.apache.org/jira/browse/FLINK-21690
[
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
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
31 matches
Mail list logo