[jira] [Comment Edited] (FLINK-19964) Gelly ITCase stuck on Azure in HITSITCase.testPrintWithRMatGraph

[ https://issues.apache.org/jira/browse/FLINK-19964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17229465#comment-17229465 ] Arvid Heise edited comment on FLINK-19964 at 11/10/20, 7:28 PM: Okay

[jira] [Commented] (FLINK-20013) BoundedBlockingSubpartition may leak network buffer if task is failed or canceled

[ https://issues.apache.org/jira/browse/FLINK-20013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17229454#comment-17229454 ] Arvid Heise commented on FLINK-20013: - Shouldn't that be backported to 1.11 (and 1.10)? >

[jira] [Commented] (FLINK-20013) BoundedBlockingSubpartition may leak network buffer if task is failed or canceled

[ https://issues.apache.org/jira/browse/FLINK-20013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17229453#comment-17229453 ] Arvid Heise commented on FLINK-20013: - Merged into master as

[jira] [Commented] (FLINK-19964) Gelly ITCase stuck on Azure in HITSITCase.testPrintWithRMatGraph

[ https://issues.apache.org/jira/browse/FLINK-19964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17229465#comment-17229465 ] Arvid Heise commented on FLINK-19964: - Okay here is what happens: * Two {{LocalBufferPool}}s are

[jira] [Commented] (FLINK-20011) PageRankITCase.testPrintWithRMatGraph hangs

[ https://issues.apache.org/jira/browse/FLINK-20011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17229828#comment-17229828 ] Arvid Heise commented on FLINK-20011: - Most likely a duplicate of FLINK-19964. >

[jira] [Commented] (FLINK-19585) UnalignedCheckpointCompatibilityITCase.test:97->runAndTakeSavepoint: "Not all required tasks are currently running."

[ https://issues.apache.org/jira/browse/FLINK-19585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17229805#comment-17229805 ] Arvid Heise commented on FLINK-19585: - The last two reports of master are FLINK-20065 (AskTimeout).

[jira] [Closed] (FLINK-20011) PageRankITCase.testPrintWithRMatGraph hangs

[ https://issues.apache.org/jira/browse/FLINK-20011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise closed FLINK-20011. --- Resolution: Duplicate > PageRankITCase.testPrintWithRMatGraph hangs >

[jira] [Commented] (FLINK-20065) UnalignedCheckpointCompatibilityITCase.test failed with AskTimeoutException

[ https://issues.apache.org/jira/browse/FLINK-20065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17229945#comment-17229945 ] Arvid Heise commented on FLINK-20065: - After some investigation, I'm rather convinced that this is

[jira] [Updated] (FLINK-20065) UnalignedCheckpointCompatibilityITCase.test failed with AskTimeoutException

[ https://issues.apache.org/jira/browse/FLINK-20065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20065: Attachment: debug.log > UnalignedCheckpointCompatibilityITCase.test failed with

[jira] [Commented] (FLINK-20065) UnalignedCheckpointCompatibilityITCase.test failed with AskTimeoutException

[ https://issues.apache.org/jira/browse/FLINK-20065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17229946#comment-17229946 ] Arvid Heise commented on FLINK-20065: - It could still be a rather specific test setup that leads to

[jira] [Updated] (FLINK-20065) UnalignedCheckpointCompatibilityITCase.test failed with AskTimeoutException

[ https://issues.apache.org/jira/browse/FLINK-20065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20065: Attachment: thread.dump > UnalignedCheckpointCompatibilityITCase.test failed with

[jira] [Resolved] (FLINK-20079) Modified UnalignedCheckpointITCase...MassivelyParallel fails

[ https://issues.apache.org/jira/browse/FLINK-20079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-20079. - Resolution: Fixed > Modified UnalignedCheckpointITCase...MassivelyParallel fails >

[jira] [Commented] (FLINK-20079) Modified UnalignedCheckpointITCase...MassivelyParallel fails

[ https://issues.apache.org/jira/browse/FLINK-20079?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17230090#comment-17230090 ] Arvid Heise commented on FLINK-20079: - Merged into master as

[jira] [Updated] (FLINK-19585) UnalignedCheckpointCompatibilityITCase.test:97->runAndTakeSavepoint: "Not all required tasks are currently running."

[ https://issues.apache.org/jira/browse/FLINK-19585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-19585: Affects Version/s: 1.11.2 > UnalignedCheckpointCompatibilityITCase.test:97->runAndTakeSavepoint:

[jira] [Commented] (FLINK-20013) BoundedBlockingSubpartition may leak network buffer if task is failed or canceled

[ https://issues.apache.org/jira/browse/FLINK-20013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17230904#comment-17230904 ] Arvid Heise commented on FLINK-20013: - Merged into 1.11 as 6626d396acbe14bbec1a9cc2ff1539ff94119046.

[jira] [Resolved] (FLINK-20013) BoundedBlockingSubpartition may leak network buffer if task is failed or canceled

[ https://issues.apache.org/jira/browse/FLINK-20013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-20013. - Resolution: Fixed > BoundedBlockingSubpartition may leak network buffer if task is failed or >

[jira] [Commented] (FLINK-20097) Race conditions in InputChannel.ChannelStatePersister

[ https://issues.apache.org/jira/browse/FLINK-20097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17230241#comment-17230241 ] Arvid Heise commented on FLINK-20097: - > In AC mode, it seems to always pass (didn't check all the

[jira] [Commented] (FLINK-20097) Race conditions in InputChannel.ChannelStatePersister

[ https://issues.apache.org/jira/browse/FLINK-20097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17230236#comment-17230236 ] Arvid Heise commented on FLINK-20097: - ``` Caused by: java.util.NoSuchElementException at

[jira] [Comment Edited] (FLINK-20097) Race conditions in InputChannel.ChannelStatePersister

[ https://issues.apache.org/jira/browse/FLINK-20097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17230236#comment-17230236 ] Arvid Heise edited comment on FLINK-20097 at 11/11/20, 9:25 PM:

[jira] [Commented] (FLINK-20097) Race conditions in InputChannel.ChannelStatePersister

[ https://issues.apache.org/jira/browse/FLINK-20097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17230235#comment-17230235 ] Arvid Heise commented on FLINK-20097: - You are right that the code currently is not behaving well

[jira] [Commented] (FLINK-19852) Managed memory released check can block IterativeTask

[ https://issues.apache.org/jira/browse/FLINK-19852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231267#comment-17231267 ] Arvid Heise commented on FLINK-19852: - Another option that I discussed with Andrey offline is to not

[jira] [Commented] (FLINK-16945) Execute CheckpointFailureManager.FailJobCallback directly in main thread executor

[ https://issues.apache.org/jira/browse/FLINK-16945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231318#comment-17231318 ] Arvid Heise commented on FLINK-16945: - I don't expect it to be part of 1.12.0. > Execute

[jira] [Assigned] (FLINK-20145) Streaming job fails with IllegalStateException: Should only poll priority events

[ https://issues.apache.org/jira/browse/FLINK-20145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-20145: --- Assignee: Arvid Heise > Streaming job fails with IllegalStateException: Should only poll

[jira] [Updated] (FLINK-16945) Execute CheckpointFailureManager.FailJobCallback directly in main thread executor

[ https://issues.apache.org/jira/browse/FLINK-16945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-16945: Priority: Major (was: Critical) > Execute CheckpointFailureManager.FailJobCallback directly in

[jira] [Updated] (FLINK-19852) Managed memory released check can block IterativeTask

[ https://issues.apache.org/jira/browse/FLINK-19852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-19852: Affects Version/s: 1.12.0 > Managed memory released check can block IterativeTask >

[jira] [Commented] (FLINK-19983) ShuffleCompressionITCase.testDataCompressionForSortMergeBlockingShuffle unstable

[ https://issues.apache.org/jira/browse/FLINK-19983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17232792#comment-17232792 ] Arvid Heise commented on FLINK-19983: - Merged into master as

[jira] [Resolved] (FLINK-19983) ShuffleCompressionITCase.testDataCompressionForSortMergeBlockingShuffle unstable

[ https://issues.apache.org/jira/browse/FLINK-19983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-19983. - Resolution: Fixed > ShuffleCompressionITCase.testDataCompressionForSortMergeBlockingShuffle >

[jira] [Resolved] (FLINK-20247) Hide unused unaligned checkpoint configuration options

[ https://issues.apache.org/jira/browse/FLINK-20247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-20247. - Fix Version/s: 1.12.0 Resolution: Fixed > Hide unused unaligned checkpoint configuration

[jira] [Commented] (FLINK-20247) Hide unused unaligned checkpoint configuration options

[ https://issues.apache.org/jira/browse/FLINK-20247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17236014#comment-17236014 ] Arvid Heise commented on FLINK-20247: - Merged into master as

[jira] [Commented] (FLINK-20030) Barrier announcement causes outdated RemoteInputChannel#numBuffersOvertaken

[ https://issues.apache.org/jira/browse/FLINK-20030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17235948#comment-17235948 ] Arvid Heise commented on FLINK-20030: - Merged into master as

[jira] [Resolved] (FLINK-20030) Barrier announcement causes outdated RemoteInputChannel#numBuffersOvertaken

[ https://issues.apache.org/jira/browse/FLINK-20030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-20030. - Resolution: Fixed > Barrier announcement causes outdated RemoteInputChannel#numBuffersOvertaken

[jira] [Commented] (FLINK-20267) JaasModule prevents Flink from starting if working directory is a symbolic link

[ https://issues.apache.org/jira/browse/FLINK-20267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17236355#comment-17236355 ] Arvid Heise commented on FLINK-20267: - There is a workaround for my setting by disabling Jaas with

[jira] [Updated] (FLINK-20247) Hide unused unaligned checkpoint configuration options

[ https://issues.apache.org/jira/browse/FLINK-20247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20247: Component/s: Runtime / Checkpointing > Hide unused unaligned checkpoint configuration options >

[jira] [Assigned] (FLINK-19864) TwoInputStreamTaskTest.testWatermarkMetrics failed with "expected:<1> but was:<-9223372036854775808>"

[ https://issues.apache.org/jira/browse/FLINK-19864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-19864: --- Assignee: Kezhu Wang > TwoInputStreamTaskTest.testWatermarkMetrics failed with

[jira] [Created] (FLINK-20247) Hide unused unaligned checkpoint configuration options

Arvid Heise created FLINK-20247: --- Summary: Hide unused unaligned checkpoint configuration options Key: FLINK-20247 URL: https://issues.apache.org/jira/browse/FLINK-20247 Project: Flink Issue

[jira] [Assigned] (FLINK-20247) Hide unused unaligned checkpoint configuration options

[ https://issues.apache.org/jira/browse/FLINK-20247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-20247: --- Assignee: Arvid Heise > Hide unused unaligned checkpoint configuration options >

[jira] [Updated] (FLINK-20247) Hide unused unaligned checkpoint configuration options

[ https://issues.apache.org/jira/browse/FLINK-20247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20247: Affects Version/s: 1.12.0 > Hide unused unaligned checkpoint configuration options >

[jira] [Commented] (FLINK-19864) TwoInputStreamTaskTest.testWatermarkMetrics failed with "expected:<1> but was:<-9223372036854775808>"

[ https://issues.apache.org/jira/browse/FLINK-19864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17235475#comment-17235475 ] Arvid Heise commented on FLINK-19864: - I assigned the ticket to you as you have done so much

[jira] [Updated] (FLINK-17726) Scheduler should take care of tasks directly canceled by TaskManager

[ https://issues.apache.org/jira/browse/FLINK-17726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-17726: Fix Version/s: (was: 1.13.0) (was: 1.11.3) (was:

[jira] [Commented] (FLINK-19864) TwoInputStreamTaskTest.testWatermarkMetrics failed with "expected:<1> but was:<-9223372036854775808>"

[ https://issues.apache.org/jira/browse/FLINK-19864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17233669#comment-17233669 ] Arvid Heise commented on FLINK-19864: - I wouldn't like to change production code to get deprecated

[jira] [Commented] (FLINK-19585) UnalignedCheckpointCompatibilityITCase.test:97->runAndTakeSavepoint: "Not all required tasks are currently running."

[ https://issues.apache.org/jira/browse/FLINK-19585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17234320#comment-17234320 ] Arvid Heise commented on FLINK-19585: - Currently [~rmetzger] is investigating unexpected behavior of

[jira] [Resolved] (FLINK-20107) Issues with setting InputChannel.statePersister

[ https://issues.apache.org/jira/browse/FLINK-20107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-20107. - Resolution: Fixed > Issues with setting InputChannel.statePersister >

[jira] [Commented] (FLINK-20107) Issues with setting InputChannel.statePersister

[ https://issues.apache.org/jira/browse/FLINK-20107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17234326#comment-17234326 ] Arvid Heise commented on FLINK-20107: - Merged into master as

[jira] [Commented] (FLINK-19585) UnalignedCheckpointCompatibilityITCase.test:97->runAndTakeSavepoint: "Not all required tasks are currently running."

[ https://issues.apache.org/jira/browse/FLINK-19585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17237271#comment-17237271 ] Arvid Heise commented on FLINK-19585: - Merged into 1.11 as 001f952f38071cbb3a76b039e324d7a9f12bf419.

[jira] [Resolved] (FLINK-19585) UnalignedCheckpointCompatibilityITCase.test:97->runAndTakeSavepoint: "Not all required tasks are currently running."

[ https://issues.apache.org/jira/browse/FLINK-19585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-19585. - Fix Version/s: 1.11.3 Resolution: Fixed >

[jira] [Commented] (FLINK-19864) TwoInputStreamTaskTest.testWatermarkMetrics failed with "expected:<1> but was:<-9223372036854775808>"

[ https://issues.apache.org/jira/browse/FLINK-19864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17237312#comment-17237312 ] Arvid Heise commented on FLINK-19864: - Merged into master as

[jira] [Resolved] (FLINK-19864) TwoInputStreamTaskTest.testWatermarkMetrics failed with "expected:<1> but was:<-9223372036854775808>"

[ https://issues.apache.org/jira/browse/FLINK-19864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-19864. - Resolution: Fixed > TwoInputStreamTaskTest.testWatermarkMetrics failed with "expected:<1> but

[jira] [Commented] (FLINK-19506) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnNonParallelLocalChannel: "Exceeded checkpoint tolerable failure threshold"

[ https://issues.apache.org/jira/browse/FLINK-19506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17230500#comment-17230500 ] Arvid Heise commented on FLINK-19506: - 2. issue is different from initial issue. The first one has

[jira] [Comment Edited] (FLINK-19864) TwoInputStreamTaskTest.testWatermarkMetrics failed with "expected:<1> but was:<-9223372036854775808>"

[ https://issues.apache.org/jira/browse/FLINK-19864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17230415#comment-17230415 ] Arvid Heise edited comment on FLINK-19864 at 11/12/20, 8:24 AM: The find

[jira] [Commented] (FLINK-19925) Errors$NativeIoException: readAddress(..) failed: Connection reset by peer

[ https://issues.apache.org/jira/browse/FLINK-19925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17230430#comment-17230430 ] Arvid Heise commented on FLINK-19925: - So for an unstable connection, there is not much that we can

[jira] [Resolved] (FLINK-19506) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnNonParallelLocalChannel: "Exceeded checkpoint tolerable failure threshold"

[ https://issues.apache.org/jira/browse/FLINK-19506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-19506. - Resolution: Cannot Reproduce >

[jira] [Commented] (FLINK-19585) UnalignedCheckpointCompatibilityITCase.test:97->runAndTakeSavepoint: "Not all required tasks are currently running."

[ https://issues.apache.org/jira/browse/FLINK-19585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17230405#comment-17230405 ] Arvid Heise commented on FLINK-19585: - Backport will happen after [~trohrmann] fixed FLINK-20065 as

[jira] [Commented] (FLINK-19864) TwoInputStreamTaskTest.testWatermarkMetrics failed with "expected:<1> but was:<-9223372036854775808>"

[ https://issues.apache.org/jira/browse/FLINK-19864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17230415#comment-17230415 ] Arvid Heise commented on FLINK-19864: - The find is most likely correct, although I don't think it's

[jira] [Commented] (FLINK-20013) BoundedBlockingSubpartition may leak network buffer if task is failed or canceled

[ https://issues.apache.org/jira/browse/FLINK-20013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17230407#comment-17230407 ] Arvid Heise commented on FLINK-20013: - Could you please create PRs for the backports, such that we

[jira] [Commented] (FLINK-20097) Race conditions in InputChannel.ChannelStatePersister

[ https://issues.apache.org/jira/browse/FLINK-20097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17230636#comment-17230636 ] Arvid Heise commented on FLINK-20097: - Merged into master as

[jira] [Resolved] (FLINK-20097) Race conditions in InputChannel.ChannelStatePersister

[ https://issues.apache.org/jira/browse/FLINK-20097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-20097. - Resolution: Fixed > Race conditions in InputChannel.ChannelStatePersister >

[jira] [Updated] (FLINK-20065) UnalignedCheckpointCompatibilityITCase.test failed with AskTimeoutException

[ https://issues.apache.org/jira/browse/FLINK-20065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20065: Component/s: (was: Runtime / Checkpointing) Runtime / Coordination >

[jira] [Commented] (FLINK-20067) "Resuming Savepoint (file, sync, scale up) end-to-end test" failed with "Could not stop with a savepoint job"

[ https://issues.apache.org/jira/browse/FLINK-20067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17230652#comment-17230652 ] Arvid Heise commented on FLINK-20067: - Yes, I agree that this may actually be the same thing.

[jira] [Resolved] (FLINK-19964) Gelly ITCase stuck on Azure in HITSITCase.testPrintWithRMatGraph

[ https://issues.apache.org/jira/browse/FLINK-19964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-19964. - Resolution: Fixed > Gelly ITCase stuck on Azure in HITSITCase.testPrintWithRMatGraph >

[jira] [Commented] (FLINK-19964) Gelly ITCase stuck on Azure in HITSITCase.testPrintWithRMatGraph

[ https://issues.apache.org/jira/browse/FLINK-19964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17229777#comment-17229777 ] Arvid Heise commented on FLINK-19964: - Yes sorry about that, but I realized that exactly that

[jira] [Assigned] (FLINK-20065) UnalignedCheckpointCompatibilityITCase.test failed with AskTimeoutException

[ https://issues.apache.org/jira/browse/FLINK-20065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-20065: --- Assignee: Arvid Heise > UnalignedCheckpointCompatibilityITCase.test failed with

[jira] [Created] (FLINK-20127) Benchmark unaligned checkpointing times under backpressure

Arvid Heise created FLINK-20127: --- Summary: Benchmark unaligned checkpointing times under backpressure Key: FLINK-20127 URL: https://issues.apache.org/jira/browse/FLINK-20127 Project: Flink

[jira] [Commented] (FLINK-20065) UnalignedCheckpointCompatibilityITCase.test failed with AskTimeoutException

[ https://issues.apache.org/jira/browse/FLINK-20065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17230591#comment-17230591 ] Arvid Heise commented on FLINK-20065: - I'd rather hand over the ticket to someone with knowledge of

[jira] [Commented] (FLINK-19924) Disallow unaligned checkpoints for iterative jobs

[ https://issues.apache.org/jira/browse/FLINK-19924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17225335#comment-17225335 ] Arvid Heise commented on FLINK-19924: - Merged into master as

[jira] [Resolved] (FLINK-19924) Disallow unaligned checkpoints for iterative jobs

[ https://issues.apache.org/jira/browse/FLINK-19924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-19924. - Resolution: Fixed > Disallow unaligned checkpoints for iterative jobs >

[jira] [Resolved] (FLINK-19907) Channel state (upstream) can be restored after emission of new elements (watermarks)

[ https://issues.apache.org/jira/browse/FLINK-19907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-19907. - Resolution: Fixed > Channel state (upstream) can be restored after emission of new elements >

[jira] [Commented] (FLINK-19907) Channel state (upstream) can be restored after emission of new elements (watermarks)

[ https://issues.apache.org/jira/browse/FLINK-19907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17225326#comment-17225326 ] Arvid Heise commented on FLINK-19907: - Also merged in release-1.11 as

[jira] [Commented] (FLINK-19856) Add EndOfChannelRecovery rescaling epoch

[ https://issues.apache.org/jira/browse/FLINK-19856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17225641#comment-17225641 ] Arvid Heise commented on FLINK-19856: - Merged into master as

[jira] [Resolved] (FLINK-19856) Add EndOfChannelRecovery rescaling epoch

[ https://issues.apache.org/jira/browse/FLINK-19856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-19856. - Resolution: Fixed > Add EndOfChannelRecovery rescaling epoch >

[jira] [Commented] (FLINK-19855) Incompatible semantics of channelIndex in UnionInputGate.resumeConsumption and its clients

[ https://issues.apache.org/jira/browse/FLINK-19855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17224496#comment-17224496 ] Arvid Heise commented on FLINK-19855: - Merged into master as

[jira] [Resolved] (FLINK-19855) Incompatible semantics of channelIndex in UnionInputGate.resumeConsumption and its clients

[ https://issues.apache.org/jira/browse/FLINK-19855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-19855. - Resolution: Fixed > Incompatible semantics of channelIndex in UnionInputGate.resumeConsumption

[jira] [Resolved] (FLINK-19632) Introduce a New ResultPartitionType for Approximate Local Recovery

[ https://issues.apache.org/jira/browse/FLINK-19632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-19632. - Resolution: Fixed > Introduce a New ResultPartitionType for Approximate Local Recovery >

[jira] [Commented] (FLINK-19632) Introduce a New ResultPartitionType for Approximate Local Recovery

[ https://issues.apache.org/jira/browse/FLINK-19632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17224491#comment-17224491 ] Arvid Heise commented on FLINK-19632: - Merged into master as

[jira] [Commented] (FLINK-19907) Channel state (upstream) can be restored after emission of new elements (watermarks)

[ https://issues.apache.org/jira/browse/FLINK-19907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17224534#comment-17224534 ] Arvid Heise commented on FLINK-19907: - [~roman_khachatryan]'s PR fixes the second case while

[jira] [Commented] (FLINK-19907) Channel state (upstream) can be restored after emission of new elements (watermarks)

[ https://issues.apache.org/jira/browse/FLINK-19907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17224536#comment-17224536 ] Arvid Heise commented on FLINK-19907: - Merged into master as

[jira] [Resolved] (FLINK-19907) Channel state (upstream) can be restored after emission of new elements (watermarks)

[ https://issues.apache.org/jira/browse/FLINK-19907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-19907. - Resolution: Fixed > Channel state (upstream) can be restored after emission of new elements >

[jira] [Commented] (FLINK-19964) Gelly ITCase stuck on Azure in HITSITCase.testPrintWithRMatGraph

[ https://issues.apache.org/jira/browse/FLINK-19964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17226077#comment-17226077 ] Arvid Heise commented on FLINK-19964: - [~roman_khachatryan] is looking into it. > Gelly ITCase

[jira] [Commented] (FLINK-19864) TwoInputStreamTaskTest.testWatermarkMetrics failed with "expected:<1> but was:<-9223372036854775808>"

[ https://issues.apache.org/jira/browse/FLINK-19864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17226589#comment-17226589 ] Arvid Heise commented on FLINK-19864: - >From my experience so far, there are no Azure-only issues.

[jira] [Commented] (FLINK-19554) Unified testing framework for connectors

[ https://issues.apache.org/jira/browse/FLINK-19554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17226758#comment-17226758 ] Arvid Heise commented on FLINK-19554: - I made good experiences with

[jira] [Resolved] (FLINK-19533) Add state assignment to channel state during rescaling

[ https://issues.apache.org/jira/browse/FLINK-19533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-19533. - Fix Version/s: 1.12.0 Resolution: Fixed > Add state assignment to channel state during

[jira] [Commented] (FLINK-19533) Add state assignment to channel state during rescaling

[ https://issues.apache.org/jira/browse/FLINK-19533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17227203#comment-17227203 ] Arvid Heise commented on FLINK-19533: - Merged into master as

[jira] [Created] (FLINK-20030) Barrier announcement causes outdated RemoteInputChannel#numBuffersOvertaken

Arvid Heise created FLINK-20030: --- Summary: Barrier announcement causes outdated RemoteInputChannel#numBuffersOvertaken Key: FLINK-20030 URL: https://issues.apache.org/jira/browse/FLINK-20030 Project:

[jira] [Updated] (FLINK-20030) Barrier announcement causes outdated RemoteInputChannel#numBuffersOvertaken

[ https://issues.apache.org/jira/browse/FLINK-20030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20030: Component/s: Runtime / Network Runtime / Checkpointing > Barrier announcement

[jira] [Updated] (FLINK-20030) Barrier announcement causes outdated RemoteInputChannel#numBuffersOvertaken

[ https://issues.apache.org/jira/browse/FLINK-20030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20030: Affects Version/s: 1.12.0 > Barrier announcement causes outdated

[jira] [Resolved] (FLINK-21044) SemanticXidGeneratorTest.testXidsUniqueAmongGenerators test failed

[ https://issues.apache.org/jira/browse/FLINK-21044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-21044. - Fix Version/s: 1.13.0 Resolution: Fixed >

[jira] [Commented] (FLINK-21044) SemanticXidGeneratorTest.testXidsUniqueAmongGenerators test failed

[ https://issues.apache.org/jira/browse/FLINK-21044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17269171#comment-17269171 ] Arvid Heise commented on FLINK-21044: - Merged into master as

[jira] [Resolved] (FLINK-20462) MailboxOperatorTest.testAvoidTaskStarvation

[ https://issues.apache.org/jira/browse/FLINK-20462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-20462. - Fix Version/s: 1.12.2 1.13.0 Resolution: Fixed >

[jira] [Commented] (FLINK-20462) MailboxOperatorTest.testAvoidTaskStarvation

[ https://issues.apache.org/jira/browse/FLINK-20462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17266653#comment-17266653 ] Arvid Heise commented on FLINK-20462: - Merged into master as

[jira] [Commented] (FLINK-20309) UnalignedCheckpointTestBase.execute is failed

[ https://issues.apache.org/jira/browse/FLINK-20309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17266654#comment-17266654 ] Arvid Heise commented on FLINK-20309: - The latest issues were test only issues. Merged a fix into

[jira] [Resolved] (FLINK-20309) UnalignedCheckpointTestBase.execute is failed

[ https://issues.apache.org/jira/browse/FLINK-20309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-20309. - Resolution: Fixed > UnalignedCheckpointTestBase.execute is failed >

[jira] [Updated] (FLINK-20309) UnalignedCheckpointTestBase.execute is failed

[ https://issues.apache.org/jira/browse/FLINK-20309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20309: Priority: Major (was: Blocker) > UnalignedCheckpointTestBase.execute is failed >

[jira] [Commented] (FLINK-20376) Error in restoring checkpoint/savepoint when Flink is upgraded from 1.9 to 1.11.2

[ https://issues.apache.org/jira/browse/FLINK-20376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17267089#comment-17267089 ] Arvid Heise commented on FLINK-20376: - Hi [~Partha Mishra], could you please clarify at which step

[jira] [Commented] (FLINK-21104) UnalignedCheckpointITCase.execute failed with "IllegalStateException"

[ https://issues.apache.org/jira/browse/FLINK-21104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17270662#comment-17270662 ] Arvid Heise commented on FLINK-21104: - Looking into it. > UnalignedCheckpointITCase.execute failed

[jira] [Comment Edited] (FLINK-20309) UnalignedCheckpointTestBase.execute is failed

[ https://issues.apache.org/jira/browse/FLINK-20309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17270012#comment-17270012 ] Arvid Heise edited comment on FLINK-20309 at 1/22/21, 9:01 AM: --- This is

[jira] [Commented] (FLINK-20309) UnalignedCheckpointTestBase.execute is failed

[ https://issues.apache.org/jira/browse/FLINK-20309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17270012#comment-17270012 ] Arvid Heise commented on FLINK-20309: - This is FLINK-20654, where I'm merging a fix in a few

[jira] [Updated] (FLINK-20654) Unaligned checkpoint recovery may lead to corrupted data stream

[ https://issues.apache.org/jira/browse/FLINK-20654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20654: Affects Version/s: 1.12.1 > Unaligned checkpoint recovery may lead to corrupted data stream >

[jira] [Resolved] (FLINK-20654) Unaligned checkpoint recovery may lead to corrupted data stream

[ https://issues.apache.org/jira/browse/FLINK-20654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-20654. - Resolution: Fixed > Unaligned checkpoint recovery may lead to corrupted data stream >

[jira] [Commented] (FLINK-20654) Unaligned checkpoint recovery may lead to corrupted data stream

[ https://issues.apache.org/jira/browse/FLINK-20654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17270361#comment-17270361 ] Arvid Heise commented on FLINK-20654: - Merged a fix into master as

[jira] [Updated] (FLINK-20654) Unaligned checkpoint recovery may lead to corrupted data stream

[ https://issues.apache.org/jira/browse/FLINK-20654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20654: Release Note: Using UnalignedCheckpoints in Flink 1.12.0 combined with two/multiple inputs tasks

[jira] [Updated] (FLINK-20654) Unaligned checkpoint recovery may lead to corrupted data stream

[ https://issues.apache.org/jira/browse/FLINK-20654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20654: Release Note: Using unaligned checkpoints in Flink 1.12.0 combined with two/multiple inputs

<    1   2   3   4   5   6   7   8   9   10   >