[jira] [Commented] (FLINK-26079) Disallow combination of Changelog backend with CLAIM restore mode when recovering from non-changelog checkpoint

[ https://issues.apache.org/jira/browse/FLINK-26079?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17490729#comment-17490729 ] Piotr Nowojski commented on FLINK-26079: {quote} The 1st option is resilient to

[jira] [Commented] (FLINK-18356) Exit code 137 returned from process

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17490714#comment-17490714 ] Piotr Nowojski commented on FLINK-18356: Another two examples of "We stopped hea

[jira] [Commented] (FLINK-26036) LocalRecoveryITCase.testRecoverLocallyFromProcessCrashWithWorkingDirectory timeout on azure

[ https://issues.apache.org/jira/browse/FLINK-26036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17490470#comment-17490470 ] Piotr Nowojski commented on FLINK-26036: https://dev.azure.com/pnowojski/Flink/_

[jira] [Closed] (FLINK-24440) Announce and combine latest watermarks across SourceReaders

[ https://issues.apache.org/jira/browse/FLINK-24440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-24440. -- Resolution: Fixed merged commit 10d6d4f into apache:master > Announce and combine latest wate

[jira] [Created] (FLINK-26064) KinesisFirehoseSinkITCase IllegalStateException: Trying to access closed classloader

Piotr Nowojski created FLINK-26064: -- Summary: KinesisFirehoseSinkITCase IllegalStateException: Trying to access closed classloader Key: FLINK-26064 URL: https://issues.apache.org/jira/browse/FLINK-26064

[jira] [Commented] (FLINK-24439) Introduce CoordinatorStore

[ https://issues.apache.org/jira/browse/FLINK-24439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489421#comment-17489421 ] Piotr Nowojski commented on FLINK-24439: The intended usage is basically the par

[jira] [Updated] (FLINK-25566) Fail to cancel task if disk is bad for java.lang.NoClassDefFoundError

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

[jira] [Commented] (FLINK-25566) Fail to cancel task if disk is bad for java.lang.NoClassDefFoundError

[ https://issues.apache.org/jira/browse/FLINK-25566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489353#comment-17489353 ] Piotr Nowojski commented on FLINK-25566: I see your point and I tend to agree, t

[jira] [Commented] (FLINK-25872) Restoring from incremental non-changelog checkpoint with changelog state-backend enabled in CLAIM mode discards state in use

[ https://issues.apache.org/jira/browse/FLINK-25872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17488851#comment-17488851 ] Piotr Nowojski commented on FLINK-25872: I'm bumping this to release blocker, as

[jira] [Updated] (FLINK-25872) Restoring from incremental non-changelog checkpoint with changelog state-backend enabled in CLAIM mode discards state in use

[ https://issues.apache.org/jira/browse/FLINK-25872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25872: --- Fix Version/s: 1.15.0 > Restoring from incremental non-changelog checkpoint with changelog

[jira] [Updated] (FLINK-25872) Restoring from incremental non-changelog checkpoint with changelog state-backend enabled in CLAIM mode discards state in use

[ https://issues.apache.org/jira/browse/FLINK-25872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25872: --- Priority: Blocker (was: Major) > Restoring from incremental non-changelog checkpoint with c

[jira] [Updated] (FLINK-23240) ResumeCheckpointManuallyITCase.testExternalizedFSCheckpointsWithLocalRecoveryZookeeper fails on azure

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

[jira] [Updated] (FLINK-25982) Support idleness with watermark alignment

[ https://issues.apache.org/jira/browse/FLINK-25982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25982: --- Description: In the PoC idleness is ignored. What it means is that even if all splits are id

[jira] [Updated] (FLINK-25982) Support idleness with watermark alignment

[ https://issues.apache.org/jira/browse/FLINK-25982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25982: --- Description: In the PoC idleness is ignored. What it means that even if all splits are idle,

[jira] [Closed] (FLINK-24439) Introduce CoordinatorStore

[ https://issues.apache.org/jira/browse/FLINK-24439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-24439. -- Resolution: Fixed merged commit 271c593 into apache:master > Introduce CoordinatorStore > ---

[jira] [Commented] (FLINK-25566) Fail to cancel task if disk is bad for java.lang.NoClassDefFoundError

[ https://issues.apache.org/jira/browse/FLINK-25566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17488133#comment-17488133 ] Piotr Nowojski commented on FLINK-25566: Hey [~Jiangang]. I'm not sure what woul

[jira] [Created] (FLINK-25982) Support idleness with watermark alignment

Piotr Nowojski created FLINK-25982: -- Summary: Support idleness with watermark alignment Key: FLINK-25982 URL: https://issues.apache.org/jira/browse/FLINK-25982 Project: Flink Issue Type: Sub

[jira] [Assigned] (FLINK-25914) Performance regression in checkpointSingleInput.UNALIGNED on 31.01.2022

[ https://issues.apache.org/jira/browse/FLINK-25914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-25914: -- Assignee: Roman Khachatryan (was: Piotr Nowojski) > Performance regression in checkp

[jira] [Updated] (FLINK-25902) NullPointerException in RescalingITCase.testSavepointRescalingOutKeyedState

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

[jira] [Updated] (FLINK-25833) FlinkUserCodeClassLoader is not registered as parallel capable

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

[jira] [Updated] (FLINK-25832) When the TaskManager is closed, its associated slot is not set to the released state.

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

[jira] [Closed] (FLINK-25827) Potential memory leaks in SourceOperator

[ https://issues.apache.org/jira/browse/FLINK-25827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-25827. -- Resolution: Fixed merged to master as d95dc864959~4..d95dc864959 merged to release-1.14 as 936

[jira] [Commented] (FLINK-24483) Document what is Public API and what compatibility guarantees Flink is providing

[ https://issues.apache.org/jira/browse/FLINK-24483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17487035#comment-17487035 ] Piotr Nowojski commented on FLINK-24483: Yes. I would still argue so. That's one

[jira] [Commented] (FLINK-25958) OOME Checkpoints & Savepoints were shown as COMPLETE in Flink UI

[ https://issues.apache.org/jira/browse/FLINK-25958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17486941#comment-17486941 ] Piotr Nowojski commented on FLINK-25958: It looks like the problem is caused by

[jira] [Updated] (FLINK-25958) OOME Checkpoints & Savepoints were shown as COMPLETE in Flink UI

[ https://issues.apache.org/jira/browse/FLINK-25958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25958: --- Affects Version/s: 1.14.3 1.12.7 1.15.0 > OOME

[jira] [Updated] (FLINK-25914) Performance regression in checkpointSingleInput.UNALIGNED on 31.01.2022

[ https://issues.apache.org/jira/browse/FLINK-25914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25914: --- Description: http://codespeed.dak8s.net:8000/timeline/?ben=checkpointSingleInput.UNALIGNED&e

[jira] [Commented] (FLINK-25914) Performance regression in checkpointSingleInput.UNALIGNED on 31.01.2022

[ https://issues.apache.org/jira/browse/FLINK-25914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17485757#comment-17485757 ] Piotr Nowojski commented on FLINK-25914: I've run bisect and have confirmed that

[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: --- Priority: Critical (was: Blocker) > UnalignedCheckpointRescaleITCase.shouldRescaleUnaligned

[jira] [Created] (FLINK-25914) Performance regression in checkpointSingleInput.UNALIGNED on 31.01.2022

Piotr Nowojski created FLINK-25914: -- Summary: Performance regression in checkpointSingleInput.UNALIGNED on 31.01.2022 Key: FLINK-25914 URL: https://issues.apache.org/jira/browse/FLINK-25914 Project:

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

[ https://issues.apache.org/jira/browse/FLINK-25704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25704: --- Issue Type: Bug (was: Improvement) > Performance regression on 18.01.2022 in batch network

[jira] [Created] (FLINK-25912) HashMapStateBackend performance regression on 31.01.2022

Piotr Nowojski created FLINK-25912: -- Summary: HashMapStateBackend performance regression on 31.01.2022 Key: FLINK-25912 URL: https://issues.apache.org/jira/browse/FLINK-25912 Project: Flink

[jira] [Commented] (FLINK-25847) KubernetesHighAvailabilityRecoverFromSavepointITCase. testRecoverFromSavepoint failed on azure

[ https://issues.apache.org/jira/browse/FLINK-25847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17485187#comment-17485187 ] Piotr Nowojski commented on FLINK-25847: [~trohrmann], could this deadlock by an

[jira] [Comment Edited] (FLINK-25847) KubernetesHighAvailabilityRecoverFromSavepointITCase. testRecoverFromSavepoint failed on azure

[ https://issues.apache.org/jira/browse/FLINK-25847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17485187#comment-17485187 ] Piotr Nowojski edited comment on FLINK-25847 at 2/1/22, 11:27 AM:

[jira] [Closed] (FLINK-25154) FLIP-193: Snapshots ownership

[ https://issues.apache.org/jira/browse/FLINK-25154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-25154. -- Resolution: Fixed > FLIP-193: Snapshots ownership > - > >

[jira] [Updated] (FLINK-25195) Use duplicating API for shared artefacts in RocksDB snapshots

[ https://issues.apache.org/jira/browse/FLINK-25195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25195: --- Fix Version/s: 1.16.0 (was: 1.15.0) > Use duplicating API for shared

[jira] [Updated] (FLINK-25195) Use duplicating API for shared artefacts in RocksDB snapshots

[ https://issues.apache.org/jira/browse/FLINK-25195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25195: --- Parent Issue: FLINK-25887 (was: FLINK-25154) > Use duplicating API for shared artefacts in

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

[ https://issues.apache.org/jira/browse/FLINK-25704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17485174#comment-17485174 ] Piotr Nowojski commented on FLINK-25704: Changes to the settings merged to flink

[jira] [Closed] (FLINK-25728) Potential memory leaks in StreamMultipleInputProcessor

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

[jira] [Assigned] (FLINK-25728) Potential memory leaks in StreamMultipleInputProcessor

[ https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-25728: -- Assignee: pc wang > Potential memory leaks in StreamMultipleInputProcessor >

[jira] [Updated] (FLINK-25896) Buffer debloating issues with high parallelism

[ https://issues.apache.org/jira/browse/FLINK-25896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25896: --- Description: As described in FLINK-25646, currently buffer debloating has performance issues

[jira] [Created] (FLINK-25896) Buffer debloating issues with high parallelism

Piotr Nowojski created FLINK-25896: -- Summary: Buffer debloating issues with high parallelism Key: FLINK-25896 URL: https://issues.apache.org/jira/browse/FLINK-25896 Project: Flink Issue Type

[jira] [Updated] (FLINK-25276) FLIP-203: 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-203: Support native and incremental savepoints (was: FLIP-182: Support native

[jira] [Assigned] (FLINK-25827) Potential memory leaks in SourceOperator

[ https://issues.apache.org/jira/browse/FLINK-25827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-25827: -- Assignee: Piotr Nowojski > Potential memory leaks in SourceOperator > ---

[jira] [Commented] (FLINK-25728) Potential memory leaks in StreamMultipleInputProcessor

[ https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17483792#comment-17483792 ] Piotr Nowojski commented on FLINK-25728: After an offline discussion with [~ches

[jira] [Created] (FLINK-25869) Create a stress test cron build

Piotr Nowojski created FLINK-25869: -- Summary: Create a stress test cron build Key: FLINK-25869 URL: https://issues.apache.org/jira/browse/FLINK-25869 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-25827) Potential memory leaks in SourceOperator

[ https://issues.apache.org/jira/browse/FLINK-25827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25827: --- Parent: (was: FLINK-25728) Issue Type: Bug (was: Sub-task) > Potential memory l

[jira] [Created] (FLINK-25827) Potential memory leaks in SourceOperator

Piotr Nowojski created FLINK-25827: -- Summary: Potential memory leaks in SourceOperator Key: FLINK-25827 URL: https://issues.apache.org/jira/browse/FLINK-25827 Project: Flink Issue Type: Sub-

[jira] [Closed] (FLINK-25590) Logging warning of insufficient memory for all configured buffers

[ https://issues.apache.org/jira/browse/FLINK-25590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-25590. -- Fix Version/s: 1.15.0 Assignee: Piotr Nowojski Resolution: Fixed Merged to mas

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

[ https://issues.apache.org/jira/browse/FLINK-25704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17482328#comment-17482328 ] Piotr Nowojski commented on FLINK-25704: Thanks for the investigation [~kevin.cy

[jira] [Commented] (FLINK-25728) Potential memory leaks in StreamMultipleInputProcessor

[ https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481954#comment-17481954 ] Piotr Nowojski commented on FLINK-25728: Thanks for the confirmation. Good catch

[jira] [Commented] (FLINK-25728) Potential memory leaks in StreamMultipleInputProcessor

[ https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481909#comment-17481909 ] Piotr Nowojski commented on FLINK-25728: Thanks for reporting and analysing the

[jira] [Updated] (FLINK-25728) Potential memory leaks in StreamMultipleInputProcessor

[ https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25728: --- Priority: Critical (was: Blocker) > Potential memory leaks in StreamMultipleInputProcessor

[jira] [Updated] (FLINK-21995) YARNSessionFIFOSecuredITCase>YARNSessionFIFOITCase.checkForProhibitedLogContents: File channel manager has shutdown.

[ https://issues.apache.org/jira/browse/FLINK-21995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-21995: --- Priority: Major (was: Not a Priority) > YARNSessionFIFOSecuredITCase>YARNSessionFIFOITCase.

[jira] [Commented] (FLINK-21995) YARNSessionFIFOSecuredITCase>YARNSessionFIFOITCase.checkForProhibitedLogContents: File channel manager has shutdown.

[ https://issues.apache.org/jira/browse/FLINK-21995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481811#comment-17481811 ] Piotr Nowojski commented on FLINK-21995: https://dev.azure.com/apache-flink/apac

[jira] [Assigned] (FLINK-25771) CassandraConnectorITCase.testRetrialAndDropTables fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-25771: -- Assignee: Etienne Chauchot > CassandraConnectorITCase.testRetrialAndDropTables fails

[jira] [Commented] (FLINK-25771) CassandraConnectorITCase.testRetrialAndDropTables fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481755#comment-17481755 ] Piotr Nowojski commented on FLINK-25771: Done [~echauchot] Another instance: ht

[jira] [Closed] (FLINK-23974) Decreased throughput with enabled buffer debloat

[ https://issues.apache.org/jira/browse/FLINK-23974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-23974. -- Resolution: Won't Fix > Decreased throughput with enabled buffer debloat > ---

[jira] [Reopened] (FLINK-23974) Decreased throughput with enabled buffer debloat

[ https://issues.apache.org/jira/browse/FLINK-23974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reopened FLINK-23974: > Decreased throughput with enabled buffer debloat > -

[jira] [Closed] (FLINK-23973) FLIP-183: Buffer debloating 1.1

[ https://issues.apache.org/jira/browse/FLINK-23973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-23973. -- Resolution: Fixed > FLIP-183: Buffer debloating 1.1 > --- > >

[jira] [Closed] (FLINK-23974) Decreased throughput with enabled buffer debloat

[ https://issues.apache.org/jira/browse/FLINK-23974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-23974. -- > Decreased throughput with enabled buffer debloat > -

[jira] [Updated] (FLINK-24191) Adjusting number of buffers besides buffer size

[ https://issues.apache.org/jira/browse/FLINK-24191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-24191: --- Parent Issue: FLINK-24589 (was: FLINK-23973) > Adjusting number of buffers besides buffer s

[jira] [Updated] (FLINK-23988) Test corner cases

[ https://issues.apache.org/jira/browse/FLINK-23988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-23988: --- Parent Issue: FLINK-24589 (was: FLINK-23973) > Test corner cases > - > >

[jira] [Comment Edited] (FLINK-15507) Activate local recovery for RocksDB backends by default

[ https://issues.apache.org/jira/browse/FLINK-15507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481139#comment-17481139 ] Piotr Nowojski edited comment on FLINK-15507 at 1/24/22, 2:36 PM:

[jira] [Commented] (FLINK-15507) Activate local recovery for RocksDB backends by default

[ https://issues.apache.org/jira/browse/FLINK-15507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481139#comment-17481139 ] Piotr Nowojski commented on FLINK-15507: I would like to resurrect the discussio

[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&focusedCommentId=17481058#comment-17481058 ] Piotr Nowojski commented on FLINK-25200: Ok, so I guess we are on the same page.

[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&focusedCommentId=17480952#comment-17480952 ] Piotr Nowojski commented on FLINK-25200: [~yunta], maybe there is some confusion

[jira] [Updated] (FLINK-25199) StreamEdges are not unique in self-union, which blocks 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, which blocks propagation of watermarks (

[jira] [Closed] (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 closed FLINK-25199. -- Resolution: Fixed merged commit 5192fd7 into apache:master 444641c9d3 to release-1.14 9c1bf6cd

[jira] [Created] (FLINK-25745) Support RocksDB incremental native savepoints

Piotr Nowojski created FLINK-25745: -- Summary: Support RocksDB incremental native savepoints Key: FLINK-25745 URL: https://issues.apache.org/jira/browse/FLINK-25745 Project: Flink Issue Type:

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

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

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

[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&focusedCommentId=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&focusedCommentId=17479437#comment-17479437 ] Piotr Nowojski commented on FLINK-25200: [~yunta], I'm not sure how much more in

[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&focusedCommentId=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&focusedCommentId=17479298#comment-17479298 ] Piotr Nowojski commented on FLINK-18450: Yes [~yoel ben]. > FLIP-182: Support w

[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&focusedCommentId=17479244#comment-17479244 ] Piotr Nowojski commented on FLINK-25199: The problem was quite strange. If there

[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 09cd1ff

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

[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&focusedCommentId=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&focusedCommentId=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 > Doc

[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&focusedCommentId=17476009#comment-17476009 ] Piotr Nowojski commented on FLINK-22643: Thanks for the analysis! Ok, sounds goo

[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 1ea2a7

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

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

[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&focusedCommentId=17472719#comment-17472719 ] Piotr Nowojski commented on FLINK-25441: I think your suggestion [~kevin.cyj] is

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

[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&focusedCommentId=17472715#comment-17472715 ] Piotr Nowojski commented on FLINK-25441: [~kevin.cyj] what do you think about th

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

[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&focusedCommentId=17472597#comment-17472597 ] Piotr Nowojski commented on FLINK-25427: {quote} What are the TMs doing that sho

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