[jira] [Assigned] (FLINK-20389) UnalignedCheckpointITCase failure caused by NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-20389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-20389: --- Assignee: Arvid Heise (was: Matthias) > UnalignedCheckpointITCase failure caused by NullPo

[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: Description: Fix of FLINK-20433 shows potential corruption after recovery for all variations of U

[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&focusedCommentId=17251864#comment-17251864 ] Arvid Heise commented on FLINK-20654: - For my investigation, I added a bunch of info

[jira] [Commented] (FLINK-20433) UnalignedCheckpointTestBase.execute failed with "TestTimedOutException: test timed out after 300 seconds"

[ https://issues.apache.org/jira/browse/FLINK-20433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17251965#comment-17251965 ] Arvid Heise commented on FLINK-20433: - Stabilized test in master as d07140c7a2dfe33a

[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&focusedCommentId=17224491#comment-17224491 ] Arvid Heise commented on FLINK-19632: - Merged into master as 1e4b380d65a54bcabceea18

[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&focusedCommentId=17224496#comment-17224496 ] Arvid Heise commented on FLINK-19855: - Merged into master as 6b5d4c0c795d50f8ff988b9

[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] [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&focusedCommentId=17224534#comment-17224534 ] Arvid Heise commented on FLINK-19907: - [~roman_khachatryan]'s PR fixes the second ca

[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&focusedCommentId=17224536#comment-17224536 ] Arvid Heise commented on FLINK-19907: - Merged into master as 3ab31a0473c01c27feb3b64

[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&focusedCommentId=17225326#comment-17225326 ] Arvid Heise commented on FLINK-19907: - Also merged in release-1.11 as 8addf891ad97ce

[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-19924) Disallow unaligned checkpoints for iterative jobs

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

[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] [Commented] (FLINK-19856) Add EndOfChannelRecovery rescaling epoch

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

[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-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&focusedCommentId=17226077#comment-17226077 ] Arvid Heise commented on FLINK-19964: - [~roman_khachatryan] is looking into it. > G

[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&focusedCommentId=17226589#comment-17226589 ] Arvid Heise commented on FLINK-19864: - >From my experience so far, there are no Azur

[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&focusedCommentId=17226758#comment-17226758 ] Arvid Heise commented on FLINK-19554: - I made good experiences with [testcontainers|

[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&focusedCommentId=17227203#comment-17227203 ] Arvid Heise commented on FLINK-19533: - Merged into master as a2267fa28a44c4cf4cc9068

[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 re

[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: Fl

[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 cau

[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 RemoteInputChannel#numBuffersOver

[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&focusedCommentId=17229290#comment-17229290 ] Arvid Heise commented on FLINK-19964: - I can confirm [~roman_khachatryan]'s find tha

[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&focusedCommentId=17229453#comment-17229453 ] Arvid Heise commented on FLINK-20013: - Merged into master as c46ae271f11075a837bf5d8

[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&focusedCommentId=17229454#comment-17229454 ] Arvid Heise commented on FLINK-20013: - Shouldn't that be backported to 1.11 (and 1.1

[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&focusedCommentId=17229465#comment-17229465 ] Arvid Heise commented on FLINK-19964: - Okay here is what happens: * Two {{LocalBuffe

[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&focusedCommentId=17229465#comment-17229465 ] Arvid Heise edited comment on FLINK-19964 at 11/10/20, 7:27 PM: --

[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&focusedCommentId=17229465#comment-17229465 ] Arvid Heise edited comment on FLINK-19964 at 11/10/20, 7:28 PM: --

[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&focusedCommentId=17229777#comment-17229777 ] Arvid Heise commented on FLINK-19964: - Yes sorry about that, but I realized that exa

[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 AskTimeoutE

[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&focusedCommentId=17229805#comment-17229805 ] Arvid Heise commented on FLINK-19585: - The last two reports of master are FLINK-2006

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

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

[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&focusedCommentId=17229945#comment-17229945 ] Arvid Heise commented on FLINK-20065: - After some investigation, I'm rather convince

[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&focusedCommentId=17229946#comment-17229946 ] Arvid Heise commented on FLINK-20065: - It could still be a rather specific test setu

[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 AskTimeoutExceptio

[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 AskTimeoutExcept

[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&focusedCommentId=17230090#comment-17230090 ] Arvid Heise commented on FLINK-20079: - Merged into master as bf16a7dd2a2786847abd440

[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-20097) Race conditions in InputChannel.ChannelStatePersister

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

[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&focusedCommentId=17230236#comment-17230236 ] Arvid Heise commented on FLINK-20097: - ``` Caused by: java.util.NoSuchElementExcepti

[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&focusedCommentId=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&focusedCommentId=17230241#comment-17230241 ] Arvid Heise commented on FLINK-20097: - > In AC mode, it seems to always pass (didn't

[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&focusedCommentId=17230405#comment-17230405 ] Arvid Heise commented on FLINK-19585: - Backport will happen after [~trohrmann] fixed

[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&focusedCommentId=17230407#comment-17230407 ] Arvid Heise commented on FLINK-20013: - Could you please create PRs for the backports

[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&focusedCommentId=17230415#comment-17230415 ] Arvid Heise commented on FLINK-19864: - The find is most likely correct, although I d

[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&focusedCommentId=17230415#comment-17230415 ] Arvid Heise edited comment on FLINK-19864 at 11/12/20, 8:24 AM: --

[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&focusedCommentId=17230430#comment-17230430 ] Arvid Heise commented on FLINK-19925: - So for an unstable connection, there is not m

[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&focusedCommentId=17230500#comment-17230500 ] Arvid Heise commented on FLINK-19506: - 2. issue is different from initial issue. The

[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 > UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnNonPa

[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&focusedCommentId=17230591#comment-17230591 ] Arvid Heise commented on FLINK-20065: - I'd rather hand over the ticket to someone wi

[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&focusedCommentId=17230636#comment-17230636 ] Arvid Heise commented on FLINK-20097: - Merged into master as 5256c210f5e0a27164c1f1e

[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 > Unaligne

[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&focusedCommentId=17230652#comment-17230652 ] Arvid Heise commented on FLINK-20067: - Yes, I agree that this may actually be the sa

[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 Issu

[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&focusedCommentId=17230904#comment-17230904 ] Arvid Heise commented on FLINK-20013: - Merged into 1.11 as 6626d396acbe14bbec1a9cc2f

[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-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&focusedCommentId=17231267#comment-17231267 ] Arvid Heise commented on FLINK-19852: - Another option that I discussed with Andrey o

[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-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&focusedCommentId=17231318#comment-17231318 ] Arvid Heise commented on FLINK-16945: - I don't expect it to be part of 1.12.0. > Ex

[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 pr

[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 ma

[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 > u

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

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

[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&focusedCommentId=17233669#comment-17233669 ] Arvid Heise commented on FLINK-19864: - I wouldn't like to change production code to

[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&focusedCommentId=17234320#comment-17234320 ] Arvid Heise commented on FLINK-19585: - Currently [~rmetzger] is investigating unexpe

[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&focusedCommentId=17234326#comment-17234326 ] Arvid Heise commented on FLINK-20107: - Merged into master as c7b2e12af37905e664685e8

[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] [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] [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 Ty

[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] [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 "expected:<1

[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&focusedCommentId=17235475#comment-17235475 ] Arvid Heise commented on FLINK-19864: - I assigned the ticket to you as you have done

[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&focusedCommentId=17235948#comment-17235948 ] Arvid Heise commented on FLINK-20030: - Merged into master as a97fe1f3f24993ff8cce2dd

[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] [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&focusedCommentId=17236014#comment-17236014 ] Arvid Heise commented on FLINK-20247: - Merged into master as 4bef0f02c27c346b4ef3a96

[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&focusedCommentId=17236355#comment-17236355 ] Arvid Heise commented on FLINK-20267: - There is a workaround for my setting by disab

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

[ https://issues.apache.org/jira/browse/FLINK-20127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20127: Attachment: Unaligned 1.12 - throughput.pdf Unaligned 1.12 - checkpoint-duration.pd

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

[ https://issues.apache.org/jira/browse/FLINK-20127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17236660#comment-17236660 ] Arvid Heise commented on FLINK-20127: - Executed Throughput job of perf-test on pre r

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

[ https://issues.apache.org/jira/browse/FLINK-20127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17236661#comment-17236661 ] Arvid Heise commented on FLINK-20127: - Migrating benchmark to new source interface t

[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&focusedCommentId=17237271#comment-17237271 ] Arvid Heise commented on FLINK-19585: - Merged into 1.11 as 001f952f38071cbb3a76b039e

[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 > UnalignedCheckpointCompatibilityITCase.test:97-

[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&focusedCommentId=17237312#comment-17237312 ] Arvid Heise commented on FLINK-19864: - Merged into master as eb500b84311717cfbc64d15

[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-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:comment-tabpanel&focusedCommentId=17237349#comment-17237349 ] Arvid Heise commented on FLINK-20145: - Merged into master as d878cacc22cf9504d07a106

[jira] [Resolved] (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 resolved FLINK-20145. - Resolution: Fixed > Streaming job fails with IllegalStateException: Should only poll priority >

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

[ https://issues.apache.org/jira/browse/FLINK-20127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-20127. - Resolution: Fixed > Benchmark unaligned checkpointing times under backpressure > ---

[jira] [Commented] (FLINK-19991) UnalignedCheckpointITCase#shouldPerformUnalignedCheckpointMassivelyParallel fails on Azure Pipeline

[ https://issues.apache.org/jira/browse/FLINK-19991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17237352#comment-17237352 ] Arvid Heise commented on FLINK-19991: - Since we done a ton of bug fixes on that fron

[jira] [Closed] (FLINK-19991) UnalignedCheckpointITCase#shouldPerformUnalignedCheckpointMassivelyParallel fails on Azure Pipeline

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

[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&focusedCommentId=17237355#comment-17237355 ] Arvid Heise commented on FLINK-19925: - Not sure what additional information I should

[jira] [Commented] (FLINK-19791) PartitionRequestClientFactoryTest.testInterruptsNotCached fails with NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-19791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17237359#comment-17237359 ] Arvid Heise commented on FLINK-19791: - I think the second issue is a duplicate of h

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