[jira] [Closed] (FLINK-35506) disable kafka auto-commit and rely on flink’s checkpointing if both are enabled

[ https://issues.apache.org/jira/browse/FLINK-35506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] elon_X closed FLINK-35506. -- Resolution: Not A Problem > disable kafka auto-commit and rely on flink’s checkpointing if both are >

[jira] [Updated] (FLINK-35506) disable kafka auto-commit and rely on flink’s checkpointing if both are enabled

[ https://issues.apache.org/jira/browse/FLINK-35506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] elon_X updated FLINK-35506: --- Description: When I use KafkaSource for consuming topics and set the Kafka parameter

[jira] [Updated] (FLINK-35506) disable kafka auto-commit and rely on flink’s checkpointing if both are enabled

[ https://issues.apache.org/jira/browse/FLINK-35506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] elon_X updated FLINK-35506: --- Description: When I use KafkaSource for consuming topics and set the Kafka parameter

[jira] [Updated] (FLINK-35506) disable kafka auto-commit and rely on flink’s checkpointing if both are enabled

[ https://issues.apache.org/jira/browse/FLINK-35506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] elon_X updated FLINK-35506: --- Attachment: image-2024-06-03-23-39-28-270.png > disable kafka auto-commit and rely on flink’s checkpointing

[jira] [Created] (FLINK-35506) disable kafka auto-commit and rely on flink’s checkpointing if both are enabled

elon_X created FLINK-35506: -- Summary: disable kafka auto-commit and rely on flink’s checkpointing if both are enabled Key: FLINK-35506 URL: https://issues.apache.org/jira/browse/FLINK-35506 Project: Flink

[jira] [Commented] (FLINK-35157) Sources with watermark alignment get stuck once some subtasks finish

[ https://issues.apache.org/jira/browse/FLINK-35157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17840443#comment-17840443 ] elon_X commented on FLINK-35157: hi, [~fanrui] Can you assign this issue to me? I can fix this problem,

[jira] [Updated] (FLINK-35157) Sources with watermark alignment get stuck once some subtasks finish

[ https://issues.apache.org/jira/browse/FLINK-35157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] elon_X updated FLINK-35157: --- Attachment: image-2024-04-24-21-36-16-146.png > Sources with watermark alignment get stuck once some

[jira] [Commented] (FLINK-35088) watermark alignment maxAllowedWatermarkDrift and updateInterval param need check

[ https://issues.apache.org/jira/browse/FLINK-35088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17840041#comment-17840041 ] elon_X commented on FLINK-35088: [~fanrui] I am very happy to fix this issue, please assign it to me,

[jira] [Comment Edited] (FLINK-35178) Checkpoint CLAIM mode does not fully control snapshot ownership

[ https://issues.apache.org/jira/browse/FLINK-35178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839522#comment-17839522 ] elon_X edited comment on FLINK-35178 at 4/22/24 3:20 PM: - [~lijinzhong]  Thank

[jira] [Commented] (FLINK-35178) Checkpoint CLAIM mode does not fully control snapshot ownership

[ https://issues.apache.org/jira/browse/FLINK-35178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839522#comment-17839522 ] elon_X commented on FLINK-35178: [~lijinzhong]  Thank you for your response. I have been using the

[jira] [Updated] (FLINK-35178) Checkpoint CLAIM mode does not fully control snapshot ownership

[ https://issues.apache.org/jira/browse/FLINK-35178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] elon_X updated FLINK-35178: --- Attachment: image-2024-04-22-15-16-02-381.png > Checkpoint CLAIM mode does not fully control snapshot

[jira] [Created] (FLINK-35178) Checkpoint CLAIM mode does not fully control snapshot ownership

elon_X created FLINK-35178: -- Summary: Checkpoint CLAIM mode does not fully control snapshot ownership Key: FLINK-35178 URL: https://issues.apache.org/jira/browse/FLINK-35178 Project: Flink Issue

[jira] [Updated] (FLINK-35160) Support for Thread Dump provides a convenient way to display issues of thread deadlocks in tasks

[ https://issues.apache.org/jira/browse/FLINK-35160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] elon_X updated FLINK-35160: --- Attachment: image-2024-04-20-14-43-36-939.png Description: After receiving feedback from the business

[jira] [Updated] (FLINK-35160) Support for Thread Dump provides a convenient way to display issues of thread deadlocks in tasks

[ https://issues.apache.org/jira/browse/FLINK-35160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] elon_X updated FLINK-35160: --- Attachment: (was: image-2024-04-18-21-00-04-532.png) > Support for Thread Dump provides a convenient

[jira] [Created] (FLINK-35160) Support for Thread Dump provides a convenient way to display issues of thread deadlocks in tasks

elon_X created FLINK-35160: -- Summary: Support for Thread Dump provides a convenient way to display issues of thread deadlocks in tasks Key: FLINK-35160 URL: https://issues.apache.org/jira/browse/FLINK-35160

[jira] [Commented] (FLINK-35088) watermark alignment maxAllowedWatermarkDrift and updateInterval param need check

[ https://issues.apache.org/jira/browse/FLINK-35088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838534#comment-17838534 ] elon_X commented on FLINK-35088: [~martijnvisser] [~masc]  I'm sorry for the late reply. I have

[jira] [Comment Edited] (FLINK-35076) Watermark alignment will cause data flow to experience serious shake

[ https://issues.apache.org/jira/browse/FLINK-35076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17836238#comment-17836238 ] elon_X edited comment on FLINK-35076 at 4/11/24 3:23 PM: - [~kkrugler]  Thank

[jira] [Commented] (FLINK-35076) Watermark alignment will cause data flow to experience serious shake

[ https://issues.apache.org/jira/browse/FLINK-35076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17836238#comment-17836238 ] elon_X commented on FLINK-35076: [~kkrugler]  Thank you for your reply. Setting the idle time is not

[jira] [Created] (FLINK-35088) watermark alignment maxAllowedWatermarkDrift and updateInterval param need check

elon_X created FLINK-35088: -- Summary: watermark alignment maxAllowedWatermarkDrift and updateInterval param need check Key: FLINK-35088 URL: https://issues.apache.org/jira/browse/FLINK-35088 Project: Flink

[jira] [Commented] (FLINK-35064) Flink sql connector pulsar/hive com.fasterxml.jackson.annotation.JsonFormat$Value conflict

[ https://issues.apache.org/jira/browse/FLINK-35064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17835964#comment-17835964 ] elon_X commented on FLINK-35064: [~chalixar] Thank you for your reply. I also used relocation to solve

[jira] [Updated] (FLINK-35076) Watermark alignment will cause data flow to experience serious shake

[ https://issues.apache.org/jira/browse/FLINK-35076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] elon_X updated FLINK-35076: --- Description: In our company, there is a requirement scenario for multi-stream join operations, we are

[jira] [Updated] (FLINK-35076) Watermark alignment will cause data flow to experience serious shake

[ https://issues.apache.org/jira/browse/FLINK-35076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] elon_X updated FLINK-35076: --- Attachment: image-2024-04-10-20-29-13-835.png > Watermark alignment will cause data flow to experience

[jira] [Updated] (FLINK-35076) Watermark alignment will cause data flow to experience serious shake

[ https://issues.apache.org/jira/browse/FLINK-35076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] elon_X updated FLINK-35076: --- Description: In our company, there is a requirement scenario for multi-stream join operations, we are

[jira] [Updated] (FLINK-35076) Watermark alignment will cause data flow to experience serious shake

[ https://issues.apache.org/jira/browse/FLINK-35076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] elon_X updated FLINK-35076: --- Attachment: image-2024-04-10-20-25-59-387.png > Watermark alignment will cause data flow to experience

[jira] [Updated] (FLINK-35076) Watermark alignment will cause data flow to experience serious shake

[ https://issues.apache.org/jira/browse/FLINK-35076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] elon_X updated FLINK-35076: --- Description: In our company, there is a requirement scenario for multi-stream join operations, we are

[jira] [Updated] (FLINK-35076) Watermark alignment will cause data flow to experience serious shake

[ https://issues.apache.org/jira/browse/FLINK-35076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] elon_X updated FLINK-35076: --- Attachment: (was: image-2024-04-10-20-13-14-752.png) > Watermark alignment will cause data flow to

[jira] [Created] (FLINK-35076) Watermark alignment will cause data flow to experience serious shake

elon_X created FLINK-35076: -- Summary: Watermark alignment will cause data flow to experience serious shake Key: FLINK-35076 URL: https://issues.apache.org/jira/browse/FLINK-35076 Project: Flink