[jira] [Updated] (FLINK-25276) FLIP-182: Support native and incremental savepoints

[ https://issues.apache.org/jira/browse/FLINK-25276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25276: --- Fix Version/s: 1.15.0 > FLIP-182: Support native and incremental savepoints >

[jira] [Updated] (FLINK-25276) FLIP-182: Support native and incremental savepoints

[ https://issues.apache.org/jira/browse/FLINK-25276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25276: --- Component/s: Runtime / Checkpointing > FLIP-182: Support native and incremental savepoints

[jira] [Updated] (FLINK-25276) FLIP-182: Support native and incremental savepoints

[ https://issues.apache.org/jira/browse/FLINK-25276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25276: --- Affects Version/s: 1.14.3 > FLIP-182: Support native and incremental savepoints >

[jira] [Created] (FLINK-25744) Support native savepoints (w/o modifying the statebackend specific snapshot strategies)

Piotr Nowojski created FLINK-25744: -- Summary: Support native savepoints (w/o modifying the statebackend specific snapshot strategies) Key: FLINK-25744 URL: https://issues.apache.org/jira/browse/FLINK-25744

[jira] [Updated] (FLINK-25276) FLIP-182: Support native and incremental savepoints

[ https://issues.apache.org/jira/browse/FLINK-25276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25276: --- Summary: FLIP-182: Support native and incremental savepoints (was: Support native and

[jira] [Updated] (FLINK-25199) StreamEdges are not unique in self-union blocking propagation of watermarks

[ https://issues.apache.org/jira/browse/FLINK-25199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25199: --- Fix Version/s: 1.13.6 1.14.4 > StreamEdges are not unique in self-union

[jira] [Updated] (FLINK-25199) StreamEdges are not unique in self-union blocking propagation of watermarks

[ https://issues.apache.org/jira/browse/FLINK-25199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25199: --- Affects Version/s: 1.13.5 1.12.7 > StreamEdges are not unique in

[jira] [Comment Edited] (FLINK-25200) Implement duplicating for s3 filesystem

[ https://issues.apache.org/jira/browse/FLINK-25200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17479437#comment-17479437 ] Piotr Nowojski edited comment on FLINK-25200 at 1/20/22, 3:11 PM: --

[jira] [Commented] (FLINK-25200) Implement duplicating for s3 filesystem

[ https://issues.apache.org/jira/browse/FLINK-25200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17479437#comment-17479437 ] Piotr Nowojski commented on FLINK-25200: [~yunta], I'm not sure how much more information would

[jira] [Comment Edited] (FLINK-18450) FLIP-182: Support watermark alignment

[ https://issues.apache.org/jira/browse/FLINK-18450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17479298#comment-17479298 ] Piotr Nowojski edited comment on FLINK-18450 at 1/20/22, 11:42 AM: ---

[jira] [Commented] (FLINK-18450) FLIP-182: Support watermark alignment

[ https://issues.apache.org/jira/browse/FLINK-18450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17479298#comment-17479298 ] Piotr Nowojski commented on FLINK-18450: Yes [~yoel ben]. > FLIP-182: Support watermark

[jira] [Commented] (FLINK-25199) StreamEdges are not unique in self-union blocking propagation of watermarks

[ https://issues.apache.org/jira/browse/FLINK-25199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17479244#comment-17479244 ] Piotr Nowojski commented on FLINK-25199: The problem was quite strange. If there was a node that

[jira] [Updated] (FLINK-25199) StreamEdges are not unique in self-union blocking propagation of watermarks

[ https://issues.apache.org/jira/browse/FLINK-25199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25199: --- Summary: StreamEdges are not unique in self-union blocking propagation of watermarks (was:

[jira] [Created] (FLINK-25704) Performance regression on 18.01.2022 in batch network benchmarks

Piotr Nowojski created FLINK-25704: -- Summary: Performance regression on 18.01.2022 in batch network benchmarks Key: FLINK-25704 URL: https://issues.apache.org/jira/browse/FLINK-25704 Project: Flink

[jira] [Assigned] (FLINK-25199) fromValues does not emit final MAX watermark

[ https://issues.apache.org/jira/browse/FLINK-25199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-25199: -- Assignee: Piotr Nowojski > fromValues does not emit final MAX watermark >

[jira] [Assigned] (FLINK-25199) fromValues does not emit final MAX watermark

[ https://issues.apache.org/jira/browse/FLINK-25199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-25199: -- Assignee: (was: Marios Trivyzas) > fromValues does not emit final MAX watermark

[jira] [Closed] (FLINK-25650) Document unaligned checkpoints performance limitations (larger records/flat map/timers/...)

[ https://issues.apache.org/jira/browse/FLINK-25650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-25650. -- Fix Version/s: 1.15.0 1.14.4 Resolution: Fixed merged commit

[jira] [Closed] (FLINK-25185) StreamFaultToleranceTestBase hangs on AZP

[ https://issues.apache.org/jira/browse/FLINK-25185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-25185. -- Resolution: Fixed The underlying issues where extracted to separate tickets FLINK-25407 and

[jira] [Comment Edited] (FLINK-25646) Document buffer debloating issues with high parallelism

[ https://issues.apache.org/jira/browse/FLINK-25646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477658#comment-17477658 ] Piotr Nowojski edited comment on FLINK-25646 at 1/18/22, 8:39 AM: --

[jira] [Created] (FLINK-25688) Resolve performance degradation with high parallelism when using buffer debloating

Piotr Nowojski created FLINK-25688: -- Summary: Resolve performance degradation with high parallelism when using buffer debloating Key: FLINK-25688 URL: https://issues.apache.org/jira/browse/FLINK-25688

[jira] [Comment Edited] (FLINK-25646) Document buffer debloating issues with high parallelism

[ https://issues.apache.org/jira/browse/FLINK-25646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477658#comment-17477658 ] Piotr Nowojski edited comment on FLINK-25646 at 1/18/22, 8:34 AM: --

[jira] [Closed] (FLINK-25646) Document buffer debloating issues with high parallelism

[ https://issues.apache.org/jira/browse/FLINK-25646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-25646. -- Fix Version/s: 1.15.0 Resolution: Fixed merged commit 25f3706 into apache:master >

[jira] [Commented] (FLINK-22643) Too many TCP connections among TaskManagers for large scale jobs

[ https://issues.apache.org/jira/browse/FLINK-22643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17476009#comment-17476009 ] Piotr Nowojski commented on FLINK-22643: Thanks for the analysis! Ok, sounds good to me, as we

[jira] [Closed] (FLINK-25407) Network stack deadlock when cancellation happens during initialisation

[ https://issues.apache.org/jira/browse/FLINK-25407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-25407. -- Resolution: Fixed Thanks [~kevin.cyj] for the fix! Merged to master as 1ea2a7a5c90^ and

[jira] [Closed] (FLINK-24918) Support to specify the data dir for state benchmark

[ https://issues.apache.org/jira/browse/FLINK-24918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-24918. -- Fix Version/s: 1.15.0 Resolution: Fixed > Support to specify the data dir for state

[jira] [Closed] (FLINK-25441) ProducerFailedException will cause task status switch from RUNNING to CANCELED, which will cause the job to hang.

[ https://issues.apache.org/jira/browse/FLINK-25441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-25441. -- Assignee: Lijie Wang Resolution: Fixed merged commit f957e3f into apache:master now >

[jira] [Commented] (FLINK-25441) ProducerFailedException will cause task status switch from RUNNING to CANCELED, which will cause the job to hang.

[ https://issues.apache.org/jira/browse/FLINK-25441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472719#comment-17472719 ] Piotr Nowojski commented on FLINK-25441: I think your suggestion [~kevin.cyj] is the right thing

[jira] (FLINK-25441) ProducerFailedException will cause task status switch from RUNNING to CANCELED, which will cause the job to hang.

[ https://issues.apache.org/jira/browse/FLINK-25441 ] Piotr Nowojski deleted comment on FLINK-25441: was (Author: pnowojski): [~kevin.cyj] what do you think about this question of mine? {quote} is the correct thing to do. A better question

[jira] [Commented] (FLINK-25441) ProducerFailedException will cause task status switch from RUNNING to CANCELED, which will cause the job to hang.

[ https://issues.apache.org/jira/browse/FLINK-25441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472715#comment-17472715 ] Piotr Nowojski commented on FLINK-25441: [~kevin.cyj] what do you think about this question of

[jira] [Closed] (FLINK-24694) Translate "Checkpointing under backpressure" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-24694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-24694. -- Resolution: Fixed Thanks for the contribution [~zlzhang0122]! merged commit d1cc458 into

[jira] [Commented] (FLINK-25427) SavepointITCase.testTriggerSavepointAndResumeWithNoClaim fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472597#comment-17472597 ] Piotr Nowojski commented on FLINK-25427: {quote} What are the TMs doing that should provide the

[jira] [Closed] (FLINK-25414) Provide metrics to measure how long task has been blocked

[ https://issues.apache.org/jira/browse/FLINK-25414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-25414. -- Fix Version/s: 1.15.0 Resolution: Fixed Merged to master as bc22d2b90cb..1166d11f61a

[jira] [Comment Edited] (FLINK-25296) [state.checkpoints.num-retained ]The default value does not take effect

[ https://issues.apache.org/jira/browse/FLINK-25296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17467258#comment-17467258 ] Piotr Nowojski edited comment on FLINK-25296 at 12/31/21, 2:15 PM: --- Hi

[jira] [Commented] (FLINK-25296) [state.checkpoints.num-retained ]The default value does not take effect

[ https://issues.apache.org/jira/browse/FLINK-25296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17467258#comment-17467258 ] Piotr Nowojski commented on FLINK-25296: Hi [~libra_816]. What do you mean by

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

[ https://issues.apache.org/jira/browse/FLINK-21186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-21186. -- Fix Version/s: 1.15.0 Resolution: Fixed Merged a small hotfix change as commit ef839ff

[jira] [Updated] (FLINK-25105) Enables final checkpoint by default

[ https://issues.apache.org/jira/browse/FLINK-25105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25105: --- Release Note: In 1.15 we enabled the support of checkpoints after part of tasks finished by

[jira] [Closed] (FLINK-25454) Negative time in throughput calculator

[ https://issues.apache.org/jira/browse/FLINK-25454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-25454. -- Resolution: Fixed > Negative time in throughput calculator >

[jira] [Updated] (FLINK-25454) Negative time in throughput calculator

[ https://issues.apache.org/jira/browse/FLINK-25454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25454: --- Affects Version/s: 1.15.0 (was: 1.14.0) > Negative time in

[jira] [Updated] (FLINK-25454) Negative time in throughput calculator

[ https://issues.apache.org/jira/browse/FLINK-25454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25454: --- Fix Version/s: 1.15.0 > Negative time in throughput calculator >

[jira] [Commented] (FLINK-25454) Negative time in throughput calculator

[ https://issues.apache.org/jira/browse/FLINK-25454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17467187#comment-17467187 ] Piotr Nowojski commented on FLINK-25454: Merged to master as 7ccd525a15c^..7ccd525a15c >

[jira] [Commented] (FLINK-22643) Too many TCP connections among TaskManagers for large scale jobs

[ https://issues.apache.org/jira/browse/FLINK-22643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17467186#comment-17467186 ] Piotr Nowojski commented on FLINK-22643: Great [~fanrui], I've assigned the ticket to you :) I

[jira] [Assigned] (FLINK-22643) Too many TCP connections among TaskManagers for large scale jobs

[ https://issues.apache.org/jira/browse/FLINK-22643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-22643: -- Assignee: fanrui > Too many TCP connections among TaskManagers for large scale jobs

[jira] [Closed] (FLINK-24657) Add metric of the total real size of input/output buffers queue

[ https://issues.apache.org/jira/browse/FLINK-24657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-24657. -- Fix Version/s: 1.15.0 Resolution: Fixed Merged to master as 60aa2ac2979^^..60aa2ac2979

[jira] [Comment Edited] (FLINK-22643) Too many TCP connections among TaskManagers for large scale jobs

[ https://issues.apache.org/jira/browse/FLINK-22643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466423#comment-17466423 ] Piotr Nowojski edited comment on FLINK-22643 at 12/31/21, 8:59 AM: ---

[jira] [Closed] (FLINK-25424) Checkpointing is currently not supported for operators that implement InputSelectable

[ https://issues.apache.org/jira/browse/FLINK-25424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-25424. -- Resolution: Duplicate Hi [~ghandzhipeng]. Thanks for rising this issue. This is a well known

[jira] [Updated] (FLINK-25307) Resuming Savepoint (hashmap, async, no parallelism change) end-to-end test timeout on azure

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

[jira] [Commented] (FLINK-25026) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466888#comment-17466888 ] Piotr Nowojski commented on FLINK-25026: Ok. In that case let's disregard those latter two

[jira] [Updated] (FLINK-25026) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails on AZP

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

[jira] [Assigned] (FLINK-25026) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-25026: -- Assignee: (was: Anton Kalashnikov) >

[jira] [Commented] (FLINK-20928) KafkaSourceReaderTest.testOffsetCommitOnCheckpointComplete:189->pollUntil:270 » Timeout

[ https://issues.apache.org/jira/browse/FLINK-20928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466872#comment-17466872 ] Piotr Nowojski commented on FLINK-20928:

[jira] [Commented] (FLINK-25026) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466852#comment-17466852 ] Piotr Nowojski commented on FLINK-25026: [~trohrmann] our best guess is/was that this, or at the

[jira] [Assigned] (FLINK-25026) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-25026: -- Assignee: Anton Kalashnikov >

[jira] [Commented] (FLINK-25441) ProducerFailedException will cause task status switch from RUNNING to CANCELED, which will cause the job to hang.

[ https://issues.apache.org/jira/browse/FLINK-25441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466731#comment-17466731 ] Piotr Nowojski commented on FLINK-25441: > because the producer (upstream task) was FINISHED.

[jira] [Closed] (FLINK-5241) Introduce AbstractStreamOperator get CloseableRegistry

[ https://issues.apache.org/jira/browse/FLINK-5241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-5241. - Resolution: Won't Fix I don't see a clear motivation to provide this improvement, so I'm closing

[jira] [Comment Edited] (FLINK-25441) ProducerFailedException will cause task status switch from RUNNING to CANCELED, which will cause the job to hang.

[ https://issues.apache.org/jira/browse/FLINK-25441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466466#comment-17466466 ] Piotr Nowojski edited comment on FLINK-25441 at 12/29/21, 2:03 PM: ---

[jira] [Commented] (FLINK-25441) ProducerFailedException will cause task status switch from RUNNING to CANCELED, which will cause the job to hang.

[ https://issues.apache.org/jira/browse/FLINK-25441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466466#comment-17466466 ] Piotr Nowojski commented on FLINK-25441: [~wanglijie95], do you mean that [exactly this

[jira] [Updated] (FLINK-25026) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails on AZP

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

[jira] [Updated] (FLINK-25426) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails on AZP because it cannot allocate enough network buffers

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

[jira] [Updated] (FLINK-25185) StreamFaultToleranceTestBase hangs on AZP

[ https://issues.apache.org/jira/browse/FLINK-25185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25185: --- Component/s: Runtime / State Backends (was: Runtime / Coordination) >

[jira] [Updated] (FLINK-25185) StreamFaultToleranceTestBase hangs on AZP

[ https://issues.apache.org/jira/browse/FLINK-25185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25185: --- Component/s: Runtime / Coordination (was: Runtime / State Backends)

[jira] [Commented] (FLINK-22643) Too many TCP connections among TaskManagers for large scale jobs

[ https://issues.apache.org/jira/browse/FLINK-22643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466423#comment-17466423 ] Piotr Nowojski commented on FLINK-22643: Currently it looks like nobody is working on this

[jira] [Closed] (FLINK-25417) Too many connections for TM

[ https://issues.apache.org/jira/browse/FLINK-25417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-25417. -- Resolution: Duplicate > Too many connections for TM > --- > >

[jira] [Updated] (FLINK-25414) Provide metrics to measure how long task has been blocked

[ https://issues.apache.org/jira/browse/FLINK-25414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25414: --- Description: Currently back pressured/busy metrics tell the user whether task is

[jira] [Assigned] (FLINK-25414) Provide metrics to measure how long task has been blocked

[ https://issues.apache.org/jira/browse/FLINK-25414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-25414: -- Assignee: Piotr Nowojski > Provide metrics to measure how long task has been blocked

[jira] [Assigned] (FLINK-25407) Network stack deadlock when cancellation happens during initialisation

[ https://issues.apache.org/jira/browse/FLINK-25407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-25407: -- Assignee: Yingjie Cao > Network stack deadlock when cancellation happens during

[jira] [Created] (FLINK-25414) Provide metrics to measure how long task has been blocked

Piotr Nowojski created FLINK-25414: -- Summary: Provide metrics to measure how long task has been blocked Key: FLINK-25414 URL: https://issues.apache.org/jira/browse/FLINK-25414 Project: Flink

[jira] [Updated] (FLINK-25395) FileNotFoundException during recovery caused by Incremental shared state being discarded by TM

[ https://issues.apache.org/jira/browse/FLINK-25395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25395: --- Priority: Blocker (was: Critical) > FileNotFoundException during recovery caused by

[jira] [Comment Edited] (FLINK-25185) StreamFaultToleranceTestBase hangs on AZP

[ https://issues.apache.org/jira/browse/FLINK-25185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463325#comment-17463325 ] Piotr Nowojski edited comment on FLINK-25185 at 12/21/21, 4:03 PM: ---

[jira] [Commented] (FLINK-25185) StreamFaultToleranceTestBase hangs on AZP

[ https://issues.apache.org/jira/browse/FLINK-25185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463325#comment-17463325 ] Piotr Nowojski commented on FLINK-25185: After an offline discussion with [~roman] and some

[jira] [Updated] (FLINK-25407) Network stack deadlock when cancellation happens during initialisation

[ https://issues.apache.org/jira/browse/FLINK-25407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25407: --- Description: This issue was extracted from and initially reported in FLINK-25185. It is

[jira] [Created] (FLINK-25407) Network stack deadlock when cancellation happens during initialisation

Piotr Nowojski created FLINK-25407: -- Summary: Network stack deadlock when cancellation happens during initialisation Key: FLINK-25407 URL: https://issues.apache.org/jira/browse/FLINK-25407 Project:

[jira] [Updated] (FLINK-25185) StreamFaultToleranceTestBase hangs on AZP

[ https://issues.apache.org/jira/browse/FLINK-25185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25185: --- Affects Version/s: 1.13.3 > StreamFaultToleranceTestBase hangs on AZP >

[jira] [Updated] (FLINK-25185) StreamFaultToleranceTestBase hangs on AZP

[ https://issues.apache.org/jira/browse/FLINK-25185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25185: --- Affects Version/s: (was: 1.13.3) > StreamFaultToleranceTestBase hangs on AZP >

[jira] [Updated] (FLINK-25395) FileNotFoundException during recovery caused by Incremental shared state being discarded by TM

[ https://issues.apache.org/jira/browse/FLINK-25395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25395: --- Summary: FileNotFoundException during recovery caused by Incremental shared state being

[jira] [Updated] (FLINK-25395) Incremental shared state might be discarded by TM

[ https://issues.apache.org/jira/browse/FLINK-25395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25395: --- Description: Extracting from [FLINK-25185

[jira] [Updated] (FLINK-25395) Incremental shared state might be discarded by TM

[ https://issues.apache.org/jira/browse/FLINK-25395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25395: --- Description: Extracting from [FLINK-25185

[jira] [Commented] (FLINK-25399) AZP fails with exit code 137 when running checkpointing test cases

[ https://issues.apache.org/jira/browse/FLINK-25399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463269#comment-17463269 ] Piotr Nowojski commented on FLINK-25399: The {{FileNotFoundException}} indicates this might be a

[jira] [Commented] (FLINK-25185) StreamFaultToleranceTestBase hangs on AZP

[ https://issues.apache.org/jira/browse/FLINK-25185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463093#comment-17463093 ] Piotr Nowojski commented on FLINK-25185: {quote} I don't think so: the decision whether to

[jira] [Updated] (FLINK-25185) StreamFaultToleranceTestBase hangs on AZP

[ https://issues.apache.org/jira/browse/FLINK-25185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25185: --- Priority: Blocker (was: Critical) > StreamFaultToleranceTestBase hangs on AZP >

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

[ https://issues.apache.org/jira/browse/FLINK-21186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-21186: -- Assignee: Piotr Nowojski > RecordWriterOutput swallows interrupt state when

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

[ https://issues.apache.org/jira/browse/FLINK-21186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463075#comment-17463075 ] Piotr Nowojski commented on FLINK-21186: I still think there is no issue in this code. It's

[jira] [Assigned] (FLINK-25194) Implement an API for duplicating artefacts

[ https://issues.apache.org/jira/browse/FLINK-25194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-25194: -- Assignee: Piotr Nowojski (was: Dawid Wysakowicz) > Implement an API for duplicating

[jira] [Commented] (FLINK-25185) StreamFaultToleranceTestBase hangs on AZP

[ https://issues.apache.org/jira/browse/FLINK-25185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17462658#comment-17462658 ] Piotr Nowojski commented on FLINK-25185: {quote} When a checkpoitnt is aborted, TM will try to

[jira] [Updated] (FLINK-25185) StreamFaultToleranceTestBase hangs on AZP

[ https://issues.apache.org/jira/browse/FLINK-25185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25185: --- Component/s: Runtime / State Backends (was: Runtime / Coordination) >

[jira] [Commented] (FLINK-25185) StreamFaultToleranceTestBase hangs on AZP

[ https://issues.apache.org/jira/browse/FLINK-25185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17462554#comment-17462554 ] Piotr Nowojski commented on FLINK-25185: It looks like those tests were stuck in an endless loop

[jira] [Updated] (FLINK-25185) StreamFaultToleranceTestBase hangs on AZP

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

[jira] [Closed] (FLINK-25382) Failure in "Upload Logs" task

[ https://issues.apache.org/jira/browse/FLINK-25382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-25382. -- Resolution: Duplicate > Failure in "Upload Logs" task > - > >

[jira] [Updated] (FLINK-22090) Upload logs fails

[ https://issues.apache.org/jira/browse/FLINK-22090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-22090: --- Priority: Critical (was: Not a Priority) > Upload logs fails > - > >

[jira] [Commented] (FLINK-22090) Upload logs fails

[ https://issues.apache.org/jira/browse/FLINK-22090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17462503#comment-17462503 ] Piotr Nowojski commented on FLINK-22090: Another instances:

[jira] [Created] (FLINK-25382) Failure in "Upload Logs" task

Piotr Nowojski created FLINK-25382: -- Summary: Failure in "Upload Logs" task Key: FLINK-25382 URL: https://issues.apache.org/jira/browse/FLINK-25382 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-25185) StreamFaultToleranceTestBase hangs on AZP

[ https://issues.apache.org/jira/browse/FLINK-25185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25185: --- Summary: StreamFaultToleranceTestBase hangs on AZP (was:

[jira] [Updated] (FLINK-25185) UdfStreamOperatorCheckpointingITCase (StreamFaultToleranceTestBase) hangs on AZP

[ https://issues.apache.org/jira/browse/FLINK-25185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25185: --- Summary: UdfStreamOperatorCheckpointingITCase (StreamFaultToleranceTestBase) hangs on AZP

[jira] [Assigned] (FLINK-25199) fromValues does not emit final MAX watermark

[ https://issues.apache.org/jira/browse/FLINK-25199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-25199: -- Assignee: Marios Trivyzas > fromValues does not emit final MAX watermark >

[jira] [Closed] (FLINK-24846) AsyncWaitOperator fails during stop-with-savepoint

[ https://issues.apache.org/jira/browse/FLINK-24846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-24846. -- Resolution: Fixed > AsyncWaitOperator fails during stop-with-savepoint >

[jira] [Comment Edited] (FLINK-24846) AsyncWaitOperator fails during stop-with-savepoint

[ https://issues.apache.org/jira/browse/FLINK-24846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17459916#comment-17459916 ] Piotr Nowojski edited comment on FLINK-24846 at 12/17/21, 11:37 AM:

[jira] [Commented] (FLINK-25318) Improvement of scheduler and execution for Flink OLAP

[ https://issues.apache.org/jira/browse/FLINK-25318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17460615#comment-17460615 ] Piotr Nowojski commented on FLINK-25318: Hi all. Thanks for taking up this interesting

[jira] [Comment Edited] (FLINK-24846) AsyncWaitOperator fails during stop-with-savepoint

[ https://issues.apache.org/jira/browse/FLINK-24846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17459916#comment-17459916 ] Piotr Nowojski edited comment on FLINK-24846 at 12/16/21, 8:08 AM: ---

[jira] [Comment Edited] (FLINK-24846) AsyncWaitOperator fails during stop-with-savepoint

[ https://issues.apache.org/jira/browse/FLINK-24846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17459916#comment-17459916 ] Piotr Nowojski edited comment on FLINK-24846 at 12/15/21, 1:57 PM: ---

[jira] [Updated] (FLINK-24846) AsyncWaitOperator fails during stop-with-savepoint

[ https://issues.apache.org/jira/browse/FLINK-24846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-24846: --- Fix Version/s: 1.13.6 > AsyncWaitOperator fails during stop-with-savepoint >

[jira] [Commented] (FLINK-24846) AsyncWaitOperator fails during stop-with-savepoint

[ https://issues.apache.org/jira/browse/FLINK-24846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17459916#comment-17459916 ] Piotr Nowojski commented on FLINK-24846: merged commit 4065bfb into apache:master merged as

<    4   5   6   7   8   9   10   11   12   13   >