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

[ https://issues.apache.org/jira/browse/FLINK-19791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-19791. - Resolution: Fixed > PartitionRequestClientFactoryTest.testInterruptsNotCached fails with > Null

[jira] [Closed] (FLINK-19536) Fix inconsistent priority notification

[ https://issues.apache.org/jira/browse/FLINK-19536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise closed FLINK-19536. --- Resolution: Duplicate FLINK-20145 seems to be the manifestation of the inconsistencies. > Fix incon

[jira] [Updated] (FLINK-19293) RocksDB last_checkpoint.state_size grows endlessly until savepoint/restore

[ https://issues.apache.org/jira/browse/FLINK-19293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-19293: Component/s: Runtime / State Backends > RocksDB last_checkpoint.state_size grows endlessly until s

[jira] [Commented] (FLINK-19293) RocksDB last_checkpoint.state_size grows endlessly until savepoint/restore

[ https://issues.apache.org/jira/browse/FLINK-19293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17237368#comment-17237368 ] Arvid Heise commented on FLINK-19293: - Sorry for the late reply. A possible reason

[jira] [Commented] (FLINK-19293) RocksDB last_checkpoint.state_size grows endlessly until savepoint/restore

[ https://issues.apache.org/jira/browse/FLINK-19293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17237388#comment-17237388 ] Arvid Heise commented on FLINK-19293: - [~yunta] do you have any other ideas or could

[jira] [Updated] (FLINK-19172) [AbstractFileStateBackend]

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

[jira] [Updated] (FLINK-19325) Optimize the consumed time for checkpoint completion

[ https://issues.apache.org/jira/browse/FLINK-19325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-19325: Fix Version/s: 1.12.0 > Optimize the consumed time for checkpoint completion > ---

[jira] [Assigned] (FLINK-19325) Optimize the consumed time for checkpoint completion

[ https://issues.apache.org/jira/browse/FLINK-19325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-19325: --- Assignee: Arvid Heise > Optimize the consumed time for checkpoint completion >

[jira] [Updated] (FLINK-19325) Optimize the consumed time for checkpoint completion

[ https://issues.apache.org/jira/browse/FLINK-19325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-19325: Affects Version/s: 1.12.0 1.11.2 > Optimize the consumed time for checkpoin

[jira] [Commented] (FLINK-19325) Optimize the consumed time for checkpoint completion

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

[jira] [Commented] (FLINK-19325) Optimize the consumed time for checkpoint completion

[ https://issues.apache.org/jira/browse/FLINK-19325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17238143#comment-17238143 ] Arvid Heise commented on FLINK-19325: - No backport to 1.11 since it's not a bug and

[jira] [Resolved] (FLINK-19325) Optimize the consumed time for checkpoint completion

[ https://issues.apache.org/jira/browse/FLINK-19325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-19325. - Resolution: Fixed > Optimize the consumed time for checkpoint completion > -

[jira] [Assigned] (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 reassigned FLINK-20309: --- Assignee: Arvid Heise > UnalignedCheckpointTestBase.execute is failed > ---

[jira] [Assigned] (FLINK-20328) UnalignedCheckpointITCase.execute failed with "Insufficient number of network buffers: required 1, but only 0 available"

[ https://issues.apache.org/jira/browse/FLINK-20328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-20328: --- Assignee: Arvid Heise > UnalignedCheckpointITCase.execute failed with "Insufficient number

[jira] [Commented] (FLINK-19027) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnParallelRemoteChannel failed because of test timeout

[ https://issues.apache.org/jira/browse/FLINK-19027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17238555#comment-17238555 ] Arvid Heise commented on FLINK-19027: - I tracked down the issue to be related by dup

[jira] [Commented] (FLINK-19027) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnParallelRemoteChannel failed because of test timeout

[ https://issues.apache.org/jira/browse/FLINK-19027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17238565#comment-17238565 ] Arvid Heise commented on FLINK-19027: - Same underlying issue as FLINK-20309, so trac

[jira] [Closed] (FLINK-19027) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnParallelRemoteChannel failed because of test timeout

[ https://issues.apache.org/jira/browse/FLINK-19027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise closed FLINK-19027. --- Resolution: Fixed > UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnParallelRemoteChanne

[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&focusedCommentId=17238568#comment-17238568 ] Arvid Heise commented on FLINK-20309: - I tracked down the issue to be related by dup

[jira] [Commented] (FLINK-20331) UnalignedCheckpointITCase.execute failed with "Sequence number for checkpoint 20 is not known (it was likely been overwritten by a newer checkpoint 21)"

[ https://issues.apache.org/jira/browse/FLINK-20331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17238585#comment-17238585 ] Arvid Heise commented on FLINK-20331: - This ticket is most likely a real bug. I hope

[jira] [Resolved] (FLINK-20328) UnalignedCheckpointITCase.execute failed with "Insufficient number of network buffers: required 1, but only 0 available"

[ https://issues.apache.org/jira/browse/FLINK-20328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-20328. - Resolution: Fixed > UnalignedCheckpointITCase.execute failed with "Insufficient number of networ

[jira] [Commented] (FLINK-20328) UnalignedCheckpointITCase.execute failed with "Insufficient number of network buffers: required 1, but only 0 available"

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

[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=17238748#comment-17238748 ] Arvid Heise commented on FLINK-19852: - Merged into master as e46ee85824796db83b994d3

[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] [Commented] (FLINK-20309) UnalignedCheckpointTestBase.execute is failed

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

[jira] [Commented] (FLINK-20331) UnalignedCheckpointITCase.execute failed with "Sequence number for checkpoint 20 is not known (it was likely been overwritten by a newer checkpoint 21)"

[ https://issues.apache.org/jira/browse/FLINK-20331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239097#comment-17239097 ] Arvid Heise commented on FLINK-20331: - Not a real bug but a too strict assumption.

[jira] [Resolved] (FLINK-20331) UnalignedCheckpointITCase.execute failed with "Sequence number for checkpoint 20 is not known (it was likely been overwritten by a newer checkpoint 21)"

[ https://issues.apache.org/jira/browse/FLINK-20331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-20331. - Resolution: Fixed > UnalignedCheckpointITCase.execute failed with "Sequence number for checkpoin

[jira] [Comment Edited] (FLINK-20331) UnalignedCheckpointITCase.execute failed with "Sequence number for checkpoint 20 is not known (it was likely been overwritten by a newer checkpoint 21)"

[ https://issues.apache.org/jira/browse/FLINK-20331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239097#comment-17239097 ] Arvid Heise edited comment on FLINK-20331 at 11/26/20, 7:18 AM: --

[jira] [Assigned] (FLINK-20383) DataSet allround end-to-end test fails with NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-20383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-20383: --- Assignee: Arvid Heise > DataSet allround end-to-end test fails with NullPointerException >

[jira] [Commented] (FLINK-20383) DataSet allround end-to-end test fails with NullPointerException

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

[jira] [Resolved] (FLINK-20383) DataSet allround end-to-end test fails with NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-20383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-20383. - Resolution: Fixed > DataSet allround end-to-end test fails with NullPointerException > -

[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 > UnalignedCheckpointITCase failure caused by NullPointerException >

[jira] [Updated] (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 updated FLINK-20389: Affects Version/s: 1.13.0 > UnalignedCheckpointITCase failure caused by NullPointerException > ---

[jira] [Updated] (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 updated FLINK-20389: Priority: Critical (was: Blocker) > UnalignedCheckpointITCase failure caused by NullPointerExcept

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

[ https://issues.apache.org/jira/browse/FLINK-20389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239580#comment-17239580 ] Arvid Heise commented on FLINK-20389: - Purely a test issue, so downgrading. Most lik

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

[ https://issues.apache.org/jira/browse/FLINK-20389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239580#comment-17239580 ] Arvid Heise edited comment on FLINK-20389 at 11/27/20, 9:04 AM: --

[jira] [Updated] (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 updated FLINK-20389: Issue Type: Bug (was: Test) > UnalignedCheckpointITCase failure caused by NullPointerException >

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

[ https://issues.apache.org/jira/browse/FLINK-20389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239604#comment-17239604 ] Arvid Heise commented on FLINK-20389: - First failure is related to {noformat} java

[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=17239718#comment-17239718 ] Arvid Heise commented on FLINK-19852: - Merged into 1.11 as 05a7875448b6f92450083c171

[jira] [Resolved] (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 resolved FLINK-19852. - Resolution: Fixed > Managed memory released check can block IterativeTask >

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

[ https://issues.apache.org/jira/browse/FLINK-20389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239815#comment-17239815 ] Arvid Heise commented on FLINK-20389: - Improved UCITCase to not fail with NPE on une

[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: Matthias (was: Arvid Heise) > UnalignedCheckpointITCase failure caused by NullPo

[jira] [Assigned] (FLINK-19249) Detect broken connections in case TCP Timeout takes too long.

[ https://issues.apache.org/jira/browse/FLINK-19249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-19249: --- Assignee: Yuan Mei > Detect broken connections in case TCP Timeout takes too long. > --

[jira] [Commented] (FLINK-16850) Make flink-benchmark align with different releases of Flink

[ https://issues.apache.org/jira/browse/FLINK-16850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17071071#comment-17071071 ] Arvid Heise commented on FLINK-16850: - For me, the main question is what is the main

[jira] [Commented] (FLINK-16917) "TPC-DS end-to-end test (Blink planner)" gets stuck

[ https://issues.apache.org/jira/browse/FLINK-16917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17073419#comment-17073419 ] Arvid Heise commented on FLINK-16917: - Hi [~ykt836] , FLINK-16245 introduced a safet

[jira] [Commented] (FLINK-16917) "TPC-DS end-to-end test (Blink planner)" gets stuck

[ https://issues.apache.org/jira/browse/FLINK-16917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17073429#comment-17073429 ] Arvid Heise commented on FLINK-16917: - :+1 to reverting FLINK-16245, I guess we need

[jira] [Commented] (FLINK-16917) "TPC-DS end-to-end test (Blink planner)" gets stuck

[ https://issues.apache.org/jira/browse/FLINK-16917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17073437#comment-17073437 ] Arvid Heise commented on FLINK-16917: - I'm assuming that something in Table API is l

[jira] [Commented] (FLINK-16850) Make flink-benchmark align with different releases of Flink

[ https://issues.apache.org/jira/browse/FLINK-16850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17074486#comment-17074486 ] Arvid Heise commented on FLINK-16850: - {quote}but explaining it to everyone that che

[jira] [Created] (FLINK-16972) Fix non-blocking output availability logic.

Arvid Heise created FLINK-16972: --- Summary: Fix non-blocking output availability logic. Key: FLINK-16972 URL: https://issues.apache.org/jira/browse/FLINK-16972 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-19027) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnParallelRemoteChannel failed because of test timeout

[ https://issues.apache.org/jira/browse/FLINK-19027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17191626#comment-17191626 ] Arvid Heise commented on FLINK-19027: - Hi [~rmetzger] , we are currently doing a lar

[jira] [Commented] (FLINK-19109) Split Reader eats chained periodic watermarks

[ https://issues.apache.org/jira/browse/FLINK-19109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17193662#comment-17193662 ] Arvid Heise commented on FLINK-19109: - Yes, it's possible to contain the fix to just

[jira] [Commented] (FLINK-19109) Split Reader eats chained periodic watermarks

[ https://issues.apache.org/jira/browse/FLINK-19109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17194350#comment-17194350 ] Arvid Heise commented on FLINK-19109: - {{Added a PR. However, I'm quite positive tha

[jira] [Comment Edited] (FLINK-19109) Split Reader eats chained periodic watermarks

[ https://issues.apache.org/jira/browse/FLINK-19109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17194350#comment-17194350 ] Arvid Heise edited comment on FLINK-19109 at 9/11/20, 3:50 PM: ---

[jira] [Comment Edited] (FLINK-19109) Split Reader eats chained periodic watermarks

[ https://issues.apache.org/jira/browse/FLINK-19109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17195670#comment-17195670 ] Arvid Heise edited comment on FLINK-19109 at 9/14/20, 6:17 PM: ---

[jira] [Commented] (FLINK-19109) Split Reader eats chained periodic watermarks

[ https://issues.apache.org/jira/browse/FLINK-19109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17195670#comment-17195670 ] Arvid Heise commented on FLINK-19109: - Since an operator can also register processin

[jira] [Commented] (FLINK-19255) Add configuration to make AsyncWaitOperation Chainable

[ https://issues.apache.org/jira/browse/FLINK-19255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17196942#comment-17196942 ] Arvid Heise commented on FLINK-19255: - Hi [~kbendick], as you have found yourself, i

[jira] [Comment Edited] (FLINK-19255) Add configuration to make AsyncWaitOperation Chainable

[ https://issues.apache.org/jira/browse/FLINK-19255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17196942#comment-17196942 ] Arvid Heise edited comment on FLINK-19255 at 9/16/20, 12:33 PM: --

[jira] [Comment Edited] (FLINK-19255) Add configuration to make AsyncWaitOperation Chainable

[ https://issues.apache.org/jira/browse/FLINK-19255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17196942#comment-17196942 ] Arvid Heise edited comment on FLINK-19255 at 9/16/20, 12:36 PM: --

[jira] [Updated] (FLINK-19109) Split Reader eats chained periodic watermarks

[ https://issues.apache.org/jira/browse/FLINK-19109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-19109: Fix Version/s: 1.10.3 > Split Reader eats chained periodic watermarks > --

[jira] [Commented] (FLINK-19109) Split Reader eats chained periodic watermarks

[ https://issues.apache.org/jira/browse/FLINK-19109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17197195#comment-17197195 ] Arvid Heise commented on FLINK-19109: - Merged in release-1.10: 05ff71c813650f65604d9

[jira] [Resolved] (FLINK-19109) Split Reader eats chained periodic watermarks

[ https://issues.apache.org/jira/browse/FLINK-19109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-19109. - Resolution: Fixed > Split Reader eats chained periodic watermarks >

[jira] [Updated] (FLINK-15467) Should wait for the end of the source thread during the Task cancellation

[ https://issues.apache.org/jira/browse/FLINK-15467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-15467: Fix Version/s: 1.10.3 > Should wait for the end of the source thread during the Task cancellation

[jira] [Commented] (FLINK-15467) Should wait for the end of the source thread during the Task cancellation

[ https://issues.apache.org/jira/browse/FLINK-15467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17197200#comment-17197200 ] Arvid Heise commented on FLINK-15467: - Merged to release-1.10 a20fb4a796d8df91e4ebbc

[jira] [Resolved] (FLINK-15467) Should wait for the end of the source thread during the Task cancellation

[ https://issues.apache.org/jira/browse/FLINK-15467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-15467. - Resolution: Fixed > Should wait for the end of the source thread during the Task cancellation >

[jira] [Assigned] (FLINK-15467) Should wait for the end of the source thread during the Task cancellation

[ https://issues.apache.org/jira/browse/FLINK-15467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-15467: --- Assignee: Roman Khachatryan > Should wait for the end of the source thread during the Task

[jira] [Commented] (FLINK-18851) Add checkpoint type to checkpoint history entries in Web UI

[ https://issues.apache.org/jira/browse/FLINK-18851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17199070#comment-17199070 ] Arvid Heise commented on FLINK-18851: - Is there already some progress? [~Kboh] alrea

[jira] [Updated] (FLINK-19338) New source interface cannot unregister unregistered source

[ https://issues.apache.org/jira/browse/FLINK-19338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-19338: Component/s: Connectors / Common > New source interface cannot unregister unregistered source > --

[jira] [Created] (FLINK-19338) New source interface cannot unregister unregistered source

Arvid Heise created FLINK-19338: --- Summary: New source interface cannot unregister unregistered source Key: FLINK-19338 URL: https://issues.apache.org/jira/browse/FLINK-19338 Project: Flink Issu

[jira] [Commented] (FLINK-19377) Task can swallow test exceptions which hides test failures

[ https://issues.apache.org/jira/browse/FLINK-19377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17200820#comment-17200820 ] Arvid Heise commented on FLINK-19377: - I dug into it and see it as a non-issue. Here

[jira] [Created] (FLINK-19391) Deadlock during partition update

Arvid Heise created FLINK-19391: --- Summary: Deadlock during partition update Key: FLINK-19391 URL: https://issues.apache.org/jira/browse/FLINK-19391 Project: Flink Issue Type: Bug Comp

[jira] [Updated] (FLINK-19391) Deadlock during partition update

[ https://issues.apache.org/jira/browse/FLINK-19391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-19391: Priority: Blocker (was: Major) > Deadlock during partition update > -

[jira] [Updated] (FLINK-19391) Deadlock during partition update

[ https://issues.apache.org/jira/browse/FLINK-19391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-19391: Description: Master cron job is currently failing because of a deadlock introduced in FLINK-19026

[jira] [Updated] (FLINK-19391) Deadlock during partition update

[ https://issues.apache.org/jira/browse/FLINK-19391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-19391: Description: Master cron job is currently failing because of a deadlock introduced in FLINK-19026

[jira] [Commented] (FLINK-19385) Channel recovery may deadlock

[ https://issues.apache.org/jira/browse/FLINK-19385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17201386#comment-17201386 ] Arvid Heise commented on FLINK-19385: - Since this issue would only occur for unalign

[jira] [Commented] (FLINK-19026) Improve threading model of Unaligner

[ https://issues.apache.org/jira/browse/FLINK-19026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17201553#comment-17201553 ] Arvid Heise commented on FLINK-19026: - Merged to master as https://github.com/apach

[jira] [Updated] (FLINK-19026) Improve threading model of Unaligner

[ https://issues.apache.org/jira/browse/FLINK-19026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-19026: Fix Version/s: 1.12.0 > Improve threading model of Unaligner > ---

[jira] [Resolved] (FLINK-19026) Improve threading model of Unaligner

[ https://issues.apache.org/jira/browse/FLINK-19026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-19026. - Resolution: Fixed > Improve threading model of Unaligner >

[jira] [Resolved] (FLINK-19391) Deadlock during partition update

[ https://issues.apache.org/jira/browse/FLINK-19391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-19391. - Resolution: Fixed > Deadlock during partition update > > >

[jira] [Resolved] (FLINK-19387) ConnectedComponentsWithDeferredUpdateITCase.testJobWithoutObjectReuse deadlock

[ https://issues.apache.org/jira/browse/FLINK-19387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-19387. - Resolution: Duplicate > ConnectedComponentsWithDeferredUpdateITCase.testJobWithoutObjectReuse de

[jira] [Commented] (FLINK-19391) Deadlock during partition update

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

[jira] [Commented] (FLINK-19387) ConnectedComponentsWithDeferredUpdateITCase.testJobWithoutObjectReuse deadlock

[ https://issues.apache.org/jira/browse/FLINK-19387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17201558#comment-17201558 ] Arvid Heise commented on FLINK-19387: - Closing this as it is subsumed by FLINK-19391

[jira] [Created] (FLINK-19400) Removed unused BufferPoolOwner

Arvid Heise created FLINK-19400: --- Summary: Removed unused BufferPoolOwner Key: FLINK-19400 URL: https://issues.apache.org/jira/browse/FLINK-19400 Project: Flink Issue Type: Bug Compon

[jira] [Assigned] (FLINK-19400) Removed unused BufferPoolOwner

[ https://issues.apache.org/jira/browse/FLINK-19400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-19400: --- Assignee: Arvid Heise > Removed unused BufferPoolOwner > -- > >

[jira] [Commented] (FLINK-19400) Removed unused BufferPoolOwner

[ https://issues.apache.org/jira/browse/FLINK-19400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17201989#comment-17201989 ] Arvid Heise commented on FLINK-19400: - I think Zhijiang already gave green light. [

[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&focusedCommentId=17267089#comment-17267089 ] Arvid Heise commented on FLINK-20376: - Hi [~Partha Mishra], could you please clarify

[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 > SemanticXidGeneratorTest.testXidsUniqueAmongGen

[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&focusedCommentId=17269171#comment-17269171 ] Arvid Heise commented on FLINK-21044: - Merged into master as 425baea4af4cdebbcb7e87d

[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&focusedCommentId=17270012#comment-17270012 ] Arvid Heise commented on FLINK-20309: - This is FLINK-20654, where I'm merging a fix

[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&focusedCommentId=17270012#comment-17270012 ] Arvid Heise edited comment on FLINK-20309 at 1/22/21, 9:01 AM: ---

[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&focusedCommentId=17270361#comment-17270361 ] Arvid Heise commented on FLINK-20654: - Merged a fix into master as 5d1c1b145fe2f5d34

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

[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&focusedCommentId=17270662#comment-17270662 ] Arvid Heise commented on FLINK-21104: - Looking into it. > UnalignedCheckpointITCase

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

[ https://issues.apache.org/jira/browse/FLINK-21104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-21104: --- Assignee: Arvid Heise > UnalignedCheckpointITCase.execute failed with "IllegalStateExceptio

[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&focusedCommentId=17271313#comment-17271313 ] Arvid Heise commented on FLINK-21104: - Merged as 1257d15fb362442dfbb39cf681161beb92b

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

[ https://issues.apache.org/jira/browse/FLINK-21104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-21104. - Resolution: Fixed > UnalignedCheckpointITCase.execute failed with "IllegalStateException" >

[jira] [Created] (FLINK-21181) Buffer pool is destroyed error when outputting data over a timer after cancellation.

Arvid Heise created FLINK-21181: --- Summary: Buffer pool is destroyed error when outputting data over a timer after cancellation. Key: FLINK-21181 URL: https://issues.apache.org/jira/browse/FLINK-21181 Pr

[jira] [Created] (FLINK-21186) RecordWriterOutput swallows interrupt state when interrupted.

Arvid Heise created FLINK-21186: --- Summary: RecordWriterOutput swallows interrupt state when interrupted. Key: FLINK-21186 URL: https://issues.apache.org/jira/browse/FLINK-21186 Project: Flink

[jira] [Assigned] (FLINK-21213) Elasticsearch (v5.3.3) sink end-to-end test' failed

[ https://issues.apache.org/jira/browse/FLINK-21213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-21213: --- Assignee: Arvid Heise > Elasticsearch (v5.3.3) sink end-to-end test' failed >

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