[jira] [Commented] (FLINK-16419) Avoid to recommit transactions which are known committed successfully to Kafka upon recovery

[ https://issues.apache.org/jira/browse/FLINK-16419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17448700#comment-17448700 ] Jiahui Jiang commented on FLINK-16419: -- [~fpaul] thank you for pointing that out. I

[jira] [Commented] (FLINK-16419) Avoid to recommit transactions which are known committed successfully to Kafka upon recovery

[ https://issues.apache.org/jira/browse/FLINK-16419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17448674#comment-17448674 ] Jiahui Jiang commented on FLINK-16419: -- [~fpaul] Correct me if I'm looking at the w

[jira] (FLINK-16419) Avoid to recommit transactions which are known committed successfully to Kafka upon recovery

[ https://issues.apache.org/jira/browse/FLINK-16419 ] Jiahui Jiang deleted comment on FLINK-16419: -- was (Author: qzhzm173227): [~fpaul] This happened in our production again today :( Does my hypothesis make sense given how Kafka generates tran

[jira] [Comment Edited] (FLINK-16419) Avoid to recommit transactions which are known committed successfully to Kafka upon recovery

[ https://issues.apache.org/jira/browse/FLINK-16419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17445945#comment-17445945 ] Jiahui Jiang edited comment on FLINK-16419 at 11/23/21, 9:05 PM: -

[jira] [Comment Edited] (FLINK-16419) Avoid to recommit transactions which are known committed successfully to Kafka upon recovery

[ https://issues.apache.org/jira/browse/FLINK-16419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17445945#comment-17445945 ] Jiahui Jiang edited comment on FLINK-16419 at 11/23/21, 9:03 PM: -

[jira] [Comment Edited] (FLINK-16419) Avoid to recommit transactions which are known committed successfully to Kafka upon recovery

[ https://issues.apache.org/jira/browse/FLINK-16419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17445945#comment-17445945 ] Jiahui Jiang edited comment on FLINK-16419 at 11/23/21, 9:00 PM: -

[jira] [Commented] (FLINK-16419) Avoid to recommit transactions which are known committed successfully to Kafka upon recovery

[ https://issues.apache.org/jira/browse/FLINK-16419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447628#comment-17447628 ] Jiahui Jiang commented on FLINK-16419: -- [~fpaul] This happened in our production ag

[jira] [Comment Edited] (FLINK-16419) Avoid to recommit transactions which are known committed successfully to Kafka upon recovery

[ https://issues.apache.org/jira/browse/FLINK-16419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17445945#comment-17445945 ] Jiahui Jiang edited comment on FLINK-16419 at 11/18/21, 3:25 PM: -

[jira] [Comment Edited] (FLINK-16419) Avoid to recommit transactions which are known committed successfully to Kafka upon recovery

[ https://issues.apache.org/jira/browse/FLINK-16419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17445945#comment-17445945 ] Jiahui Jiang edited comment on FLINK-16419 at 11/18/21, 2:30 PM: -

[jira] [Commented] (FLINK-16419) Avoid to recommit transactions which are known committed successfully to Kafka upon recovery

[ https://issues.apache.org/jira/browse/FLINK-16419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17445945#comment-17445945 ] Jiahui Jiang commented on FLINK-16419: -- [~fpaul] we actually set it to be super hig

[jira] [Comment Edited] (FLINK-16419) Avoid to recommit transactions which are known committed successfully to Kafka upon recovery

[ https://issues.apache.org/jira/browse/FLINK-16419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17444812#comment-17444812 ] Jiahui Jiang edited comment on FLINK-16419 at 11/17/21, 10:11 PM:

[jira] [Comment Edited] (FLINK-16419) Avoid to recommit transactions which are known committed successfully to Kafka upon recovery

[ https://issues.apache.org/jira/browse/FLINK-16419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17444812#comment-17444812 ] Jiahui Jiang edited comment on FLINK-16419 at 11/16/21, 9:22 PM: -

[jira] [Commented] (FLINK-16419) Avoid to recommit transactions which are known committed successfully to Kafka upon recovery

[ https://issues.apache.org/jira/browse/FLINK-16419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17444812#comment-17444812 ] Jiahui Jiang commented on FLINK-16419: -- [~becket_qin] [~qinjunjerry]  We are seein

[jira] [Commented] (FLINK-17173) Supports query hint to config "IdleStateRetentionTime" per operator in SQL

[ https://issues.apache.org/jira/browse/FLINK-17173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17090202#comment-17090202 ] Jiahui Jiang commented on FLINK-17173: -- [~danny0405] I just saw your [design doc|[

[jira] [Commented] (FLINK-17173) Supports query hint to config "IdleStateRetentionTime" per query in SQL

[ https://issues.apache.org/jira/browse/FLINK-17173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17086655#comment-17086655 ] Jiahui Jiang commented on FLINK-17173: -- [~danny0405] I'd love to contribute the fea

[jira] [Commented] (FLINK-17173) Supports query hint to config "IdleStateRetentionTime" per query in SQL

[ https://issues.apache.org/jira/browse/FLINK-17173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17084921#comment-17084921 ] Jiahui Jiang commented on FLINK-17173: -- Right now idleStateRetentionTime config is