[jira] [Updated] (FLINK-25202) Implement duplicating for azure

[ https://issues.apache.org/jira/browse/FLINK-25202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-25202: - Fix Version/s: 1.16.0 (was: 1.15.0) > Implement duplicating for

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

[ https://issues.apache.org/jira/browse/FLINK-25200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-25200: - Fix Version/s: 1.16.0 (was: 1.15.0) > Implement duplicating for

[jira] [Updated] (FLINK-25201) Implement duplicating for gcs

[ https://issues.apache.org/jira/browse/FLINK-25201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-25201: - Fix Version/s: 1.16.0 (was: 1.15.0) > Implement duplicating for

[jira] [Updated] (FLINK-25203) Implement duplicating for aliyun

[ https://issues.apache.org/jira/browse/FLINK-25203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-25203: - Fix Version/s: 1.16.0 (was: 1.15.0) > Implement duplicating for

[jira] [Updated] (FLINK-25202) Implement duplicating for azure

[ https://issues.apache.org/jira/browse/FLINK-25202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-25202: - Parent Issue: FLINK-25887 (was: FLINK-25154) > Implement duplicating for azure >

[jira] [Updated] (FLINK-25203) Implement duplicating for aliyun

[ https://issues.apache.org/jira/browse/FLINK-25203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-25203: - Parent Issue: FLINK-25887 (was: FLINK-25154) > Implement duplicating for aliyun >

[jira] [Updated] (FLINK-25322) Support no-claim mode in changelog state backend

[ https://issues.apache.org/jira/browse/FLINK-25322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-25322: - Parent Issue: FLINK-25887 (was: FLINK-25154) > Support no-claim mode in changelog

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

[ https://issues.apache.org/jira/browse/FLINK-25200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-25200: - Parent Issue: FLINK-25887 (was: FLINK-25154) > Implement duplicating for s3 filesystem

[jira] [Updated] (FLINK-25201) Implement duplicating for gcs

[ https://issues.apache.org/jira/browse/FLINK-25201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-25201: - Parent Issue: FLINK-25887 (was: FLINK-25154) > Implement duplicating for gcs >

[jira] [Created] (FLINK-25887) FLIP-193: Snapshots ownership follow ups

Dawid Wysakowicz created FLINK-25887: Summary: FLIP-193: Snapshots ownership follow ups Key: FLINK-25887 URL: https://issues.apache.org/jira/browse/FLINK-25887 Project: Flink Issue Type:

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

[ https://issues.apache.org/jira/browse/FLINK-25154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17481627#comment-17481627 ] Dawid Wysakowicz edited comment on FLINK-25154 at 1/25/22, 1:35 PM:

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

[ https://issues.apache.org/jira/browse/FLINK-25154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17481627#comment-17481627 ] Dawid Wysakowicz edited comment on FLINK-25154 at 1/25/22, 1:34 PM:

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

[ https://issues.apache.org/jira/browse/FLINK-25154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17481627#comment-17481627 ] Dawid Wysakowicz edited comment on FLINK-25154 at 1/25/22, 1:34 PM:

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

[ https://issues.apache.org/jira/browse/FLINK-25154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17481627#comment-17481627 ] Dawid Wysakowicz edited comment on FLINK-25154 at 1/25/22, 1:34 PM:

[jira] [Commented] (FLINK-13856) Reduce the delete file api when the checkpoint is completed

[ https://issues.apache.org/jira/browse/FLINK-13856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17481712#comment-17481712 ] Dawid Wysakowicz commented on FLINK-13856: -- A POC for bulk deleting files:

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

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-18356: Assignee: (was: Dawid Wysakowicz) > Exit code 137 returned from process >

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

[ https://issues.apache.org/jira/browse/FLINK-25154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17481627#comment-17481627 ] Dawid Wysakowicz commented on FLINK-25154: -- Sorry, [~monster#12] I missed the notification.

[jira] [Comment Edited] (FLINK-25683) wrong result if table transfrom to DataStream then window process in batch mode

[ https://issues.apache.org/jira/browse/FLINK-25683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17480910#comment-17480910 ] Dawid Wysakowicz edited comment on FLINK-25683 at 1/24/22, 4:03 PM:

[jira] [Updated] (FLINK-25683) wrong result if table transfrom to DataStream then window process in batch mode

[ https://issues.apache.org/jira/browse/FLINK-25683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-25683: - Fix Version/s: 1.13.6 > wrong result if table transfrom to DataStream then window

[jira] [Comment Edited] (FLINK-25683) wrong result if table transfrom to DataStream then window process in batch mode

[ https://issues.apache.org/jira/browse/FLINK-25683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17480910#comment-17480910 ] Dawid Wysakowicz edited comment on FLINK-25683 at 1/24/22, 4:03 PM:

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

[ https://issues.apache.org/jira/browse/FLINK-25745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-25745: Assignee: Dawid Wysakowicz > Support RocksDB incremental native savepoints >

[jira] [Closed] (FLINK-25683) wrong result if table transfrom to DataStream then window process in batch mode

[ https://issues.apache.org/jira/browse/FLINK-25683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-25683. Resolution: Fixed > wrong result if table transfrom to DataStream then window process in

[jira] [Updated] (FLINK-25683) wrong result if table transfrom to DataStream then window process in batch mode

[ https://issues.apache.org/jira/browse/FLINK-25683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-25683: - Fix Version/s: 1.15.0 1.14.4 > wrong result if table transfrom to

[jira] [Commented] (FLINK-25683) wrong result if table transfrom to DataStream then window process in batch mode

[ https://issues.apache.org/jira/browse/FLINK-25683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17480910#comment-17480910 ] Dawid Wysakowicz commented on FLINK-25683: -- Fixed in: * master **

[jira] [Commented] (FLINK-25751) flink-table tests exit with code 137

[ https://issues.apache.org/jira/browse/FLINK-25751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17480062#comment-17480062 ] Dawid Wysakowicz commented on FLINK-25751: -- Still, thanks for reporting ;) > flink-table tests

[jira] [Commented] (FLINK-25751) flink-table tests exit with code 137

[ https://issues.apache.org/jira/browse/FLINK-25751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17480044#comment-17480044 ] Dawid Wysakowicz commented on FLINK-25751: -- The title does not say anything about python

[jira] [Comment Edited] (FLINK-25751) flink-table tests exit with code 137

[ https://issues.apache.org/jira/browse/FLINK-25751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17480044#comment-17480044 ] Dawid Wysakowicz edited comment on FLINK-25751 at 1/21/22, 12:37 PM: -

[jira] [Comment Edited] (FLINK-25751) flink-table tests exit with code 137

[ https://issues.apache.org/jira/browse/FLINK-25751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17480044#comment-17480044 ] Dawid Wysakowicz edited comment on FLINK-25751 at 1/21/22, 12:37 PM: -

[jira] [Closed] (FLINK-25751) flink-table tests exit with code 137

[ https://issues.apache.org/jira/browse/FLINK-25751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-25751. Resolution: Duplicate I'd treat it as the same problem as FLINK-18356 > flink-table

[jira] [Comment Edited] (FLINK-25683) wrong result if table transfrom to DataStream then window process in batch mode

[ https://issues.apache.org/jira/browse/FLINK-25683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17479357#comment-17479357 ] Dawid Wysakowicz edited comment on FLINK-25683 at 1/20/22, 1:15 PM:

[jira] [Comment Edited] (FLINK-25683) wrong result if table transfrom to DataStream then window process in batch mode

[ https://issues.apache.org/jira/browse/FLINK-25683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17479357#comment-17479357 ] Dawid Wysakowicz edited comment on FLINK-25683 at 1/20/22, 1:15 PM:

[jira] [Commented] (FLINK-25683) wrong result if table transfrom to DataStream then window process in batch mode

[ https://issues.apache.org/jira/browse/FLINK-25683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17479357#comment-17479357 ] Dawid Wysakowicz commented on FLINK-25683: -- I can't explain you where does the flag comes from,

[jira] [Comment Edited] (FLINK-25683) wrong result if table transfrom to DataStream then window process in batch mode

[ https://issues.apache.org/jira/browse/FLINK-25683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17479357#comment-17479357 ] Dawid Wysakowicz edited comment on FLINK-25683 at 1/20/22, 1:14 PM:

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

[ https://issues.apache.org/jira/browse/FLINK-25427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-25427. Resolution: Fixed Fixed in 00856d068931a5988347b9bdbdf11bc700258fe1 >

[jira] [Commented] (FLINK-25683) wrong result if table transfrom to DataStream then window process in batch mode

[ https://issues.apache.org/jira/browse/FLINK-25683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17479234#comment-17479234 ] Dawid Wysakowicz commented on FLINK-25683: -- [~twalthr] I can't think of any other case, where

[jira] [Commented] (FLINK-25683) wrong result if table transfrom to DataStream then window process in batch mode

[ https://issues.apache.org/jira/browse/FLINK-25683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17479152#comment-17479152 ] Dawid Wysakowicz commented on FLINK-25683: -- Sorry, I have not spotted that before. Actually, I

[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=17479121#comment-17479121 ] Dawid Wysakowicz commented on FLINK-18356: -- [~trohrmann] No, we have not merged any changes to

[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=17478686#comment-17478686 ] Dawid Wysakowicz commented on FLINK-25200: -- > Do you ensure that the test logic is reading

[jira] [Commented] (FLINK-25683) wrong result if table transfrom to DataStream then window process in batch mode

[ https://issues.apache.org/jira/browse/FLINK-25683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17478619#comment-17478619 ] Dawid Wysakowicz commented on FLINK-25683: -- Hi [~paul8263]. This is a very good investigation.

[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=17478581#comment-17478581 ] Dawid Wysakowicz commented on FLINK-18356: -- [~MartijnVisser] It definitely would not harm. Not

[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 ] Dawid Wysakowicz reassigned FLINK-25194: Assignee: Dawid Wysakowicz (was: Piotr Nowojski) > Implement an API for

[jira] [Closed] (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 ] Dawid Wysakowicz closed FLINK-25194. Resolution: Implemented Implemented in fc1d63579ae5bcd9db207e1a5cd1b6365a87e871 >

[jira] [Closed] (FLINK-25193) Document claim & no-claim mode

[ https://issues.apache.org/jira/browse/FLINK-25193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-25193. Resolution: Implemented Documented in 6f2769ebfe336a6965be588b138e3660bb7723a4 >

[jira] [Closed] (FLINK-25160) Make doc clear: tolerable-failed-checkpoints counts consecutive failures

[ https://issues.apache.org/jira/browse/FLINK-25160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-25160. Fix Version/s: 1.15.0 1.13.6 1.14.4

[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=17476183#comment-17476183 ] Dawid Wysakowicz commented on FLINK-18356: -- I was not able to figure out anything new about the

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

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-18356: Assignee: Dawid Wysakowicz (was: Piotr Nowojski) > Exit code 137 returned from

[jira] [Commented] (FLINK-25322) Support no-claim mode in changelog state backend

[ https://issues.apache.org/jira/browse/FLINK-25322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17461511#comment-17461511 ] Dawid Wysakowicz commented on FLINK-25322: -- Once implemented we should revert:

[jira] [Closed] (FLINK-25192) Implement proper no-claim mode support

[ https://issues.apache.org/jira/browse/FLINK-25192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-25192. Resolution: Implemented Implemented in 08794a6b2188268c3de6b134f399228415c7fc8f >

[jira] [Assigned] (FLINK-25193) Document claim & no-claim mode

[ https://issues.apache.org/jira/browse/FLINK-25193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-25193: Assignee: Dawid Wysakowicz > Document claim & no-claim mode >

[jira] [Closed] (FLINK-25191) Skip savepoints for recovery

[ https://issues.apache.org/jira/browse/FLINK-25191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-25191. Resolution: Implemented Implemented in

[jira] [Created] (FLINK-25322) Support no-claim mode in changelog state backend

Dawid Wysakowicz created FLINK-25322: Summary: Support no-claim mode in changelog state backend Key: FLINK-25322 URL: https://issues.apache.org/jira/browse/FLINK-25322 Project: Flink

[jira] [Commented] (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:comment-tabpanel=17459715#comment-17459715 ] Dawid Wysakowicz commented on FLINK-25307: -- Looking at logs it seems that we do not even reach

[jira] [Updated] (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:all-tabpanel ] Dawid Wysakowicz updated FLINK-25296: - Component/s: Runtime / Coordination > [state.checkpoints.num-retained ]The default

[jira] [Commented] (FLINK-25267) Unable to (always) recover using checkpoint in HA setup (both Zookeeper and Kubernetes)

[ https://issues.apache.org/jira/browse/FLINK-25267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17459320#comment-17459320 ] Dawid Wysakowicz commented on FLINK-25267: -- Could it be that somehow you're running more than

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

[ https://issues.apache.org/jira/browse/FLINK-25154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-25154: Assignee: Dawid Wysakowicz > FLIP-193: Snapshots ownership >

[jira] [Updated] (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 ] Dawid Wysakowicz updated FLINK-25199: - Component/s: (was: Table SQL / Runtime) > fromValues does not emit final MAX

[jira] [Updated] (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 ] Dawid Wysakowicz updated FLINK-25199: - Component/s: Runtime / Task > 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 ] Dawid Wysakowicz reassigned FLINK-25199: Assignee: Dawid Wysakowicz (was: Marios Trivyzas) > fromValues does not emit

[jira] [Assigned] (FLINK-25191) Skip savepoints for recovery

[ https://issues.apache.org/jira/browse/FLINK-25191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-25191: Assignee: Dawid Wysakowicz > Skip savepoints for recovery >

[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 ] Dawid Wysakowicz reassigned FLINK-25194: Assignee: Dawid Wysakowicz > Implement an API for duplicating artefacts >

[jira] [Assigned] (FLINK-25192) Implement proper no-claim mode support

[ https://issues.apache.org/jira/browse/FLINK-25192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-25192: Assignee: Dawid Wysakowicz > Implement proper no-claim mode support >

[jira] [Commented] (FLINK-25256) Savepoints do not work with ExternallyInducedSources

[ https://issues.apache.org/jira/browse/FLINK-25256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17457060#comment-17457060 ] Dawid Wysakowicz commented on FLINK-25256: -- cc [~pnowojski] > Savepoints do not work with

[jira] [Created] (FLINK-25256) Savepoints do not work with ExternallyInducedSources

Dawid Wysakowicz created FLINK-25256: Summary: Savepoints do not work with ExternallyInducedSources Key: FLINK-25256 URL: https://issues.apache.org/jira/browse/FLINK-25256 Project: Flink

[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=17456483#comment-17456483 ] Dawid Wysakowicz commented on FLINK-20928: -- I've seen this one quite often recently in PR CIs

[jira] [Closed] (FLINK-25155) Implement claim snapshot mode

[ https://issues.apache.org/jira/browse/FLINK-25155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-25155. Resolution: Implemented Implemented in

[jira] [Closed] (FLINK-23532) Unify stop-with-savepoint w drain and w/o drain

[ https://issues.apache.org/jira/browse/FLINK-23532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-23532. Resolution: Implemented Implemented in

[jira] [Updated] (FLINK-25191) Skip savepoints for recovery

[ https://issues.apache.org/jira/browse/FLINK-25191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-25191: - Description: Intermediate savepoints should not be used for recovery. In order to

[jira] [Updated] (FLINK-25192) Implement proper no-claim mode support

[ https://issues.apache.org/jira/browse/FLINK-25192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-25192: - Description: In the no-claim mode should not depend on any artefacts of the initial

[jira] [Updated] (FLINK-25201) Implement duplicating for gcs

[ https://issues.apache.org/jira/browse/FLINK-25201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-25201: - Component/s: FileSystems (was: Connectors / FileSystem) >

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

[ https://issues.apache.org/jira/browse/FLINK-25200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-25200: - Component/s: FileSystems (was: Connectors / FileSystem) >

[jira] [Created] (FLINK-25203) Implement duplicating for aliyun

Dawid Wysakowicz created FLINK-25203: Summary: Implement duplicating for aliyun Key: FLINK-25203 URL: https://issues.apache.org/jira/browse/FLINK-25203 Project: Flink Issue Type:

[jira] [Updated] (FLINK-25202) Implement duplicating for azure

[ https://issues.apache.org/jira/browse/FLINK-25202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-25202: - Component/s: FileSystems (was: Connectors / FileSystem) >

[jira] [Created] (FLINK-25202) Implement duplicating for azure

Dawid Wysakowicz created FLINK-25202: Summary: Implement duplicating for azure Key: FLINK-25202 URL: https://issues.apache.org/jira/browse/FLINK-25202 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-25201) Implement duplicating for gcs

Dawid Wysakowicz created FLINK-25201: Summary: Implement duplicating for gcs Key: FLINK-25201 URL: https://issues.apache.org/jira/browse/FLINK-25201 Project: Flink Issue Type: Sub-task

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

Dawid Wysakowicz created FLINK-25200: Summary: Implement duplicating for s3 filesystem Key: FLINK-25200 URL: https://issues.apache.org/jira/browse/FLINK-25200 Project: Flink Issue Type:

[jira] [Updated] (FLINK-25192) Implement proper no-claim mode support

[ https://issues.apache.org/jira/browse/FLINK-25192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-25192: - Component/s: Runtime / State Backends > Implement proper no-claim mode support >

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

Dawid Wysakowicz created FLINK-25195: Summary: Use duplicating API for shared artefacts in RocksDB snapshots Key: FLINK-25195 URL: https://issues.apache.org/jira/browse/FLINK-25195 Project: Flink

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

Dawid Wysakowicz created FLINK-25194: Summary: Implement an API for duplicating artefacts Key: FLINK-25194 URL: https://issues.apache.org/jira/browse/FLINK-25194 Project: Flink Issue

[jira] [Created] (FLINK-25193) Document claim & no-claim mode

Dawid Wysakowicz created FLINK-25193: Summary: Document claim & no-claim mode Key: FLINK-25193 URL: https://issues.apache.org/jira/browse/FLINK-25193 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-25192) Implement proper no-claim mode support

Dawid Wysakowicz created FLINK-25192: Summary: Implement proper no-claim mode support Key: FLINK-25192 URL: https://issues.apache.org/jira/browse/FLINK-25192 Project: Flink Issue Type:

[jira] [Created] (FLINK-25191) Skip savepoints for recovery

Dawid Wysakowicz created FLINK-25191: Summary: Skip savepoints for recovery Key: FLINK-25191 URL: https://issues.apache.org/jira/browse/FLINK-25191 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-25155) Implement claim snapshot mode

Dawid Wysakowicz created FLINK-25155: Summary: Implement claim snapshot mode Key: FLINK-25155 URL: https://issues.apache.org/jira/browse/FLINK-25155 Project: Flink Issue Type: Sub-task

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

Dawid Wysakowicz created FLINK-25154: Summary: FLIP-193: Snapshots ownership Key: FLINK-25154 URL: https://issues.apache.org/jira/browse/FLINK-25154 Project: Flink Issue Type:

[jira] [Comment Edited] (FLINK-24919) UnalignedCheckpointITCase hangs on Azure

[ https://issues.apache.org/jira/browse/FLINK-24919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452237#comment-17452237 ] Dawid Wysakowicz edited comment on FLINK-24919 at 12/2/21, 4:02 PM:

[jira] [Closed] (FLINK-24919) UnalignedCheckpointITCase hangs on Azure

[ https://issues.apache.org/jira/browse/FLINK-24919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-24919. Fix Version/s: 1.14.1 1.13.4 Resolution: Fixed >

[jira] [Commented] (FLINK-24919) UnalignedCheckpointITCase hangs on Azure

[ https://issues.apache.org/jira/browse/FLINK-24919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452237#comment-17452237 ] Dawid Wysakowicz commented on FLINK-24919: -- Fixed in: * master **

[jira] [Updated] (FLINK-24919) UnalignedCheckpointITCase hangs on Azure

[ https://issues.apache.org/jira/browse/FLINK-24919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-24919: - Fix Version/s: 1.15.0 > UnalignedCheckpointITCase hangs on Azure >

[jira] [Updated] (FLINK-13856) Reduce the delete file api when the checkpoint is completed

[ https://issues.apache.org/jira/browse/FLINK-13856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-13856: - Fix Version/s: 1.15.0 > Reduce the delete file api when the checkpoint is completed >

[jira] [Updated] (FLINK-13856) Reduce the delete file api when the checkpoint is completed

[ https://issues.apache.org/jira/browse/FLINK-13856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-13856: - Priority: Major (was: Not a Priority) > Reduce the delete file api when the checkpoint

[jira] [Updated] (FLINK-13856) Reduce the delete file api when the checkpoint is completed

[ https://issues.apache.org/jira/browse/FLINK-13856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-13856: - Labels: pull-request-available (was: auto-unassigned pull-request-available

[jira] [Assigned] (FLINK-23532) Unify stop-with-savepoint w drain and w/o drain

[ https://issues.apache.org/jira/browse/FLINK-23532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-23532: Assignee: Dawid Wysakowicz > Unify stop-with-savepoint w drain and w/o drain >

[jira] [Closed] (FLINK-21467) Document possible recommended usage of Bounded{One/Multi}Input.endInput and emphasize that they could be called multiple times

[ https://issues.apache.org/jira/browse/FLINK-21467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-21467. Fix Version/s: 1.15.0 1.14.1 1.13.4

[jira] [Closed] (FLINK-24294) Resources leak in the StreamTask constructor

[ https://issues.apache.org/jira/browse/FLINK-24294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-24294. Fix Version/s: 1.15.0 Resolution: Fixed Fixed in: * master **

[jira] [Updated] (FLINK-24328) Long term fix for receiving new buffer size before network reader configured

[ https://issues.apache.org/jira/browse/FLINK-24328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-24328: - Fix Version/s: (was: 1.14.1) > Long term fix for receiving new buffer size before

[jira] [Closed] (FLINK-24938) Checkpoint cleaner is closed before checkpoints are discarded

[ https://issues.apache.org/jira/browse/FLINK-24938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-24938. Resolution: Duplicate > Checkpoint cleaner is closed before checkpoints are discarded >

[jira] [Updated] (FLINK-24858) TypeSerializer version mismatch during eagerly restore

[ https://issues.apache.org/jira/browse/FLINK-24858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-24858: - Fix Version/s: 1.15.0 1.14.1 1.13.4 >

[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=17443651#comment-17443651 ] Dawid Wysakowicz commented on FLINK-24846: -- [~gaoyunhaii] We won't call {{finish}} for

[jira] [Closed] (FLINK-24690) Clarification of buffer size threshold calculation in BufferDebloater

[ https://issues.apache.org/jira/browse/FLINK-24690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-24690. Resolution: Fixed Fixed in: * master ** 6c82d0b2c5fce2d1bdea61cbc5d713e10945d44f * 1.14.1

[jira] [Closed] (FLINK-24552) Ineffective buffer debloat configuration in randomized tests

[ https://issues.apache.org/jira/browse/FLINK-24552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-24552. Resolution: Fixed Fixed: * master ** d687f6527948cea33e80655b27499960ea2f414e * 1.14.1 **

[jira] [Comment Edited] (FLINK-24800) BufferTimeoutITCase.testDisablingBufferTimeout failed on Azure

[ https://issues.apache.org/jira/browse/FLINK-24800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17442285#comment-17442285 ] Dawid Wysakowicz edited comment on FLINK-24800 at 11/12/21, 12:59 PM:

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