[jira] [Commented] (FLINK-33109) Watermark alignment not applied after recovery from checkpoint

[ https://issues.apache.org/jira/browse/FLINK-33109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846747#comment-17846747 ] Yordan Pavlov commented on FLINK-33109: --- Hi [~pnowojski] , yes we do not observe t

[jira] [Comment Edited] (FLINK-33109) Watermark alignment not applied after recovery from checkpoint

[ https://issues.apache.org/jira/browse/FLINK-33109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17772616#comment-17772616 ] Yordan Pavlov edited comment on FLINK-33109 at 10/6/23 3:44 PM: --

[jira] [Updated] (FLINK-33109) Watermark alignment not applied after recovery from checkpoint

[ https://issues.apache.org/jira/browse/FLINK-33109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yordan Pavlov updated FLINK-33109: -- Attachment: (was: WatermarkTest.scala) > Watermark alignment not applied after recovery fr

[jira] [Updated] (FLINK-33109) Watermark alignment not applied after recovery from checkpoint

[ https://issues.apache.org/jira/browse/FLINK-33109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yordan Pavlov updated FLINK-33109: -- Attachment: WatermarkTest-1.scala > Watermark alignment not applied after recovery from checkp

[jira] [Commented] (FLINK-33109) Watermark alignment not applied after recovery from checkpoint

[ https://issues.apache.org/jira/browse/FLINK-33109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17772616#comment-17772616 ] Yordan Pavlov commented on FLINK-33109: --- Hi [~fanrui]  sorry for the delay, runni

[jira] [Updated] (FLINK-33109) Watermark alignment not applied after recovery from checkpoint

[ https://issues.apache.org/jira/browse/FLINK-33109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yordan Pavlov updated FLINK-33109: -- Attachment: WatermarkTest.scala > Watermark alignment not applied after recovery from checkpoi

[jira] [Commented] (FLINK-33109) Watermark alignment not applied after recovery from checkpoint

[ https://issues.apache.org/jira/browse/FLINK-33109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767012#comment-17767012 ] Yordan Pavlov commented on FLINK-33109: --- Hi [~fanrui] can I ask for your help in t

[jira] [Commented] (FLINK-33109) Watermark alignment not applied after recovery from checkpoint

[ https://issues.apache.org/jira/browse/FLINK-33109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17766464#comment-17766464 ] Yordan Pavlov commented on FLINK-33109: --- I'll give a try the 1.17.2 and 1.18.0 cod

[jira] [Created] (FLINK-33109) Watermark alignment not applied after recovery from checkpoint

Yordan Pavlov created FLINK-33109: - Summary: Watermark alignment not applied after recovery from checkpoint Key: FLINK-33109 URL: https://issues.apache.org/jira/browse/FLINK-33109 Project: Flink

[jira] [Commented] (FLINK-31970) "Key group 0 is not in KeyGroupRange" when using CheckpointedFunction

[ https://issues.apache.org/jira/browse/FLINK-31970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17757978#comment-17757978 ] Yordan Pavlov commented on FLINK-31970: --- Hi, [~masteryhx]  I do not experience the

[jira] [Commented] (FLINK-31970) "Key group 0 is not in KeyGroupRange" when using CheckpointedFunction

[ https://issues.apache.org/jira/browse/FLINK-31970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17723194#comment-17723194 ] Yordan Pavlov commented on FLINK-31970: --- First and foremost thank you for your inp

[jira] [Created] (FLINK-31970) "Key group 0 is not in KeyGroupRange" when using CheckpointedFunction

Yordan Pavlov created FLINK-31970: - Summary: "Key group 0 is not in KeyGroupRange" when using CheckpointedFunction Key: FLINK-31970 URL: https://issues.apache.org/jira/browse/FLINK-31970 Project: Flin

[jira] [Created] (FLINK-31727) Source parallelism should match number of Kafka partitions

Yordan Pavlov created FLINK-31727: - Summary: Source parallelism should match number of Kafka partitions Key: FLINK-31727 URL: https://issues.apache.org/jira/browse/FLINK-31727 Project: Flink

[jira] [Created] (FLINK-31304) Very slow job start if topic has been used before

Yordan Pavlov created FLINK-31304: - Summary: Very slow job start if topic has been used before Key: FLINK-31304 URL: https://issues.apache.org/jira/browse/FLINK-31304 Project: Flink Issue Typ

[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=17634383#comment-17634383 ] Yordan Pavlov commented on FLINK-16419: --- Thanks [~pnowojski] for your extensive ex

[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=17624315#comment-17624315 ] Yordan Pavlov commented on FLINK-16419: --- Let me try to provide some more info on h

[jira] [Updated] (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:all-tabpanel ] Yordan Pavlov updated FLINK-16419: -- Attachment: tm0-transaction.log > Avoid to recommit transactions which are known committed suc

[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=17622315#comment-17622315 ] Yordan Pavlov commented on FLINK-16419: --- Again, thanks for you input [~martijnviss

[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=17621314#comment-17621314 ] Yordan Pavlov commented on FLINK-16419: --- Thanks for your feedback [~martijnvisser]

[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=17621220#comment-17621220 ] Yordan Pavlov commented on FLINK-16419: --- [~martijnvisser] This issue has plagued o

[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=17580807#comment-17580807 ] Yordan Pavlov commented on FLINK-16419: --- We are having considerable difficulties w

[jira] [Created] (FLINK-28802) EOFException when recovering from a checkpoint

Yordan Pavlov created FLINK-28802: - Summary: EOFException when recovering from a checkpoint Key: FLINK-28802 URL: https://issues.apache.org/jira/browse/FLINK-28802 Project: Flink Issue Type:

[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=17563927#comment-17563927 ] Yordan Pavlov commented on FLINK-16419: --- Savepoint usability shouldn't be bound to

[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=17563894#comment-17563894 ] Yordan Pavlov commented on FLINK-16419: --- [~martijnvisser] From what you are saying

[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=17563715#comment-17563715 ] Yordan Pavlov commented on FLINK-16419: --- [~martijnvisser] Yes, quite a lot. I am t

[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=17563616#comment-17563616 ] Yordan Pavlov commented on FLINK-16419: --- [~martijnvisser]  I am still seeing the i

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

Title: Message Title Yordan Pavlov comment

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

Title: Message Title Yordan Pavlov comment

[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=17531594#comment-17531594 ] Yordan Pavlov commented on FLINK-16419: --- I am experiencing a similar issue, recove

[jira] [Commented] (FLINK-16267) Flink uses more memory than taskmanager.memory.process.size in Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-16267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17421216#comment-17421216 ] Yordan Pavlov commented on FLINK-16267: --- [~gunjansharma1409] We work-around it, wh

[jira] [Commented] (FLINK-5996) Jobmanager HA should not crash on lost ZK node

[ https://issues.apache.org/jira/browse/FLINK-5996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17273816#comment-17273816 ] Yordan Pavlov commented on FLINK-5996: -- Thanks for your prompt reply [~trohrmann],

[jira] [Comment Edited] (FLINK-5996) Jobmanager HA should not crash on lost ZK node

[ https://issues.apache.org/jira/browse/FLINK-5996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17273760#comment-17273760 ] Yordan Pavlov edited comment on FLINK-5996 at 1/28/21, 2:18 PM: ---

[jira] [Comment Edited] (FLINK-5996) Jobmanager HA should not crash on lost ZK node

[ https://issues.apache.org/jira/browse/FLINK-5996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17273760#comment-17273760 ] Yordan Pavlov edited comment on FLINK-5996 at 1/28/21, 2:18 PM: ---

[jira] [Commented] (FLINK-5996) Jobmanager HA should not crash on lost ZK node

[ https://issues.apache.org/jira/browse/FLINK-5996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17273760#comment-17273760 ] Yordan Pavlov commented on FLINK-5996: -- Discovered this ticket looking for explanati

[jira] [Commented] (FLINK-16267) Flink uses more memory than taskmanager.memory.process.size in Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-16267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17266157#comment-17266157 ] Yordan Pavlov commented on FLINK-16267: --- Thank you guys [~yunta], [~xintongsong] y

[jira] [Commented] (FLINK-16267) Flink uses more memory than taskmanager.memory.process.size in Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-16267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17264740#comment-17264740 ] Yordan Pavlov commented on FLINK-16267: --- [~azagrebin] Do we consider the problem w

[jira] [Commented] (FLINK-16267) Flink uses more memory than taskmanager.memory.process.size in Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-16267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17264194#comment-17264194 ] Yordan Pavlov commented on FLINK-16267: --- I have came back to this ticket to invest

[jira] [Commented] (FLINK-20698) A single object is reused among windows with different key

[ https://issues.apache.org/jira/browse/FLINK-20698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17252971#comment-17252971 ] Yordan Pavlov commented on FLINK-20698: --- OK, thanks for looking into this. > A si

[jira] [Updated] (FLINK-20698) A single object is reused among windows with different key

[ https://issues.apache.org/jira/browse/FLINK-20698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yordan Pavlov updated FLINK-20698: -- Summary: A single object is reused among windows with different key (was: A single ojbect is

[jira] [Created] (FLINK-20698) A single ojbect is reused among windows with different key

Yordan Pavlov created FLINK-20698: - Summary: A single ojbect is reused among windows with different key Key: FLINK-20698 URL: https://issues.apache.org/jira/browse/FLINK-20698 Project: Flink

[jira] [Commented] (FLINK-16267) Flink uses more memory than taskmanager.memory.process.size in Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-16267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17168538#comment-17168538 ] Yordan Pavlov commented on FLINK-16267: --- Hi [~xintongsong], sorry for the late rep

[jira] [Commented] (FLINK-16267) Flink uses more memory than taskmanager.memory.process.size in Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-16267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17159038#comment-17159038 ] Yordan Pavlov commented on FLINK-16267: --- Hello, I am the next one suffering from

[jira] [Commented] (FLINK-17800) RocksDB optimizeForPointLookup results in missing time windows

[ https://issues.apache.org/jira/browse/FLINK-17800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17118820#comment-17118820 ] Yordan Pavlov commented on FLINK-17800: --- Hello [~yunta], I am sorry for using int

[jira] [Updated] (FLINK-17800) RocksDB optimizeForPointLookup results in missing time windows

[ https://issues.apache.org/jira/browse/FLINK-17800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yordan Pavlov updated FLINK-17800: -- Attachment: MyMissingWindows.scala > RocksDB optimizeForPointLookup results in missing time wi

[jira] [Commented] (FLINK-17800) RocksDB optimizeForPointLookup results in missing time windows

[ https://issues.apache.org/jira/browse/FLINK-17800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111864#comment-17111864 ] Yordan Pavlov commented on FLINK-17800: --- [~yunta] Yes the attachment reproduces t

[jira] [Commented] (FLINK-17800) RocksDB optimizeForPointLookup results in missing time windows

[ https://issues.apache.org/jira/browse/FLINK-17800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111047#comment-17111047 ] Yordan Pavlov commented on FLINK-17800: --- [~yunta] Thanks for picking up on this pr

[jira] [Updated] (FLINK-17800) RocksDB optimizeForPointLookup results in missing time windows

[ https://issues.apache.org/jira/browse/FLINK-17800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yordan Pavlov updated FLINK-17800: -- Attachment: MissingWindows.scala > RocksDB optimizeForPointLookup results in missing time wind

[jira] [Updated] (FLINK-17800) RocksDB optimizeForPointLookup results in missing time windows

[ https://issues.apache.org/jira/browse/FLINK-17800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yordan Pavlov updated FLINK-17800: -- Description: +My Setup:+ We have been using the _RocksDb_ option of _optimizeForPointLookup_

[jira] [Updated] (FLINK-17800) RocksDB optimizeForPointLookup results in missing time windows

[ https://issues.apache.org/jira/browse/FLINK-17800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yordan Pavlov updated FLINK-17800: -- Description: +My Setup:+ We have been using the _RocksDb_ option of _optimizeForPointLookup_

[jira] [Created] (FLINK-17800) RocksDB optimizeForPointLookup results in missing time windows

Yordan Pavlov created FLINK-17800: - Summary: RocksDB optimizeForPointLookup results in missing time windows Key: FLINK-17800 URL: https://issues.apache.org/jira/browse/FLINK-17800 Project: Flink