Re: [PR] [FLINK-34615]Split `ExternalizedCheckpointCleanup` out of `Checkpoint… [flink]

2024-05-17 Thread via GitHub
Zakelly commented on PR #24461: URL: https://github.com/apache/flink/pull/24461#issuecomment-2116919484 I modified the commit message and remove those 'cherry-picked from x'. Already merged into master. -- This is an automated message from the Apache Git Service. To respond to the

Re: [PR] [FLINK-34615]Split `ExternalizedCheckpointCleanup` out of `Checkpoint… [flink]

2024-05-17 Thread via GitHub
Zakelly closed pull request #24461: [FLINK-34615]Split `ExternalizedCheckpointCleanup` out of `Checkpoint… URL: https://github.com/apache/flink/pull/24461 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to

Re: [PR] [FLINK-34615]Split `ExternalizedCheckpointCleanup` out of `Checkpoint… [flink]

2024-05-17 Thread via GitHub
spoon-lz commented on PR #24461: URL: https://github.com/apache/flink/pull/24461#issuecomment-2116868581 @Zakelly Flink-ci has passed -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

Re: [PR] [FLINK-34615]Split `ExternalizedCheckpointCleanup` out of `Checkpoint… [flink]

2024-05-15 Thread via GitHub
spoon-lz commented on PR #24461: URL: https://github.com/apache/flink/pull/24461#issuecomment-2111766768 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment.

Re: [PR] [FLINK-34615]Split `ExternalizedCheckpointCleanup` out of `Checkpoint… [flink]

2024-05-12 Thread via GitHub
spoon-lz commented on PR #24461: URL: https://github.com/apache/flink/pull/24461#issuecomment-2106510219 @Zakelly @masteryhx A new `ExternalizedCheckpointRetention.py` is created, the old one is marked as deprecated, and a separate commit for the python part is split. -- This is an

Re: [PR] [FLINK-34615]Split `ExternalizedCheckpointCleanup` out of `Checkpoint… [flink]

2024-05-11 Thread via GitHub
spoon-lz commented on PR #24461: URL: https://github.com/apache/flink/pull/24461#issuecomment-2105643136 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

Re: [PR] [FLINK-34615]Split `ExternalizedCheckpointCleanup` out of `Checkpoint… [flink]

2024-05-09 Thread via GitHub
Zakelly commented on PR #24461: URL: https://github.com/apache/flink/pull/24461#issuecomment-2102128570 @spoon-lz sorry for the late reply. I agreed with @masteryhx that we'd better create another new class and deprecate the old one in python. -- This is an automated message from the

Re: [PR] [FLINK-34615]Split `ExternalizedCheckpointCleanup` out of `Checkpoint… [flink]

2024-05-07 Thread via GitHub
masteryhx commented on code in PR #24461: URL: https://github.com/apache/flink/pull/24461#discussion_r1591876771 ## flink-python/docs/reference/pyflink.datastream/checkpoint.rst: ## @@ -81,7 +81,7 @@ The default limit of concurrently happening checkpoints: one.

Re: [PR] [FLINK-34615]Split `ExternalizedCheckpointCleanup` out of `Checkpoint… [flink]

2024-05-07 Thread via GitHub
masteryhx commented on code in PR #24461: URL: https://github.com/apache/flink/pull/24461#discussion_r1591864040 ## flink-python/docs/reference/pyflink.datastream/checkpoint.rst: ## @@ -81,7 +81,7 @@ The default limit of concurrently happening checkpoints: one.

Re: [PR] [FLINK-34615]Split `ExternalizedCheckpointCleanup` out of `Checkpoint… [flink]

2024-05-06 Thread via GitHub
spoon-lz commented on PR #24461: URL: https://github.com/apache/flink/pull/24461#issuecomment-2097311563 @Zakelly @masteryhx What further discussions are needed on the modification of the python part? This PR has been on hold for some time. -- This is an automated message from the

Re: [PR] [FLINK-34615]Split `ExternalizedCheckpointCleanup` out of `Checkpoint… [flink]

2024-04-17 Thread via GitHub
spoon-lz commented on code in PR #24461: URL: https://github.com/apache/flink/pull/24461#discussion_r1568676454 ## flink-python/docs/reference/pyflink.datastream/checkpoint.rst: ## @@ -81,7 +81,7 @@ The default limit of concurrently happening checkpoints: one.

Re: [PR] [FLINK-34615]Split `ExternalizedCheckpointCleanup` out of `Checkpoint… [flink]

2024-04-11 Thread via GitHub
spoon-lz commented on PR #24461: URL: https://github.com/apache/flink/pull/24461#issuecomment-2049266369 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment.

Re: [PR] [FLINK-34615]Split `ExternalizedCheckpointCleanup` out of `Checkpoint… [flink]

2024-04-10 Thread via GitHub
Zakelly commented on code in PR #24461: URL: https://github.com/apache/flink/pull/24461#discussion_r1560407149 ## flink-python/docs/reference/pyflink.datastream/checkpoint.rst: ## @@ -81,7 +81,7 @@ The default limit of concurrently happening checkpoints: one.

Re: [PR] [FLINK-34615]Split `ExternalizedCheckpointCleanup` out of `Checkpoint… [flink]

2024-04-10 Thread via GitHub
masteryhx commented on code in PR #24461: URL: https://github.com/apache/flink/pull/24461#discussion_r1560402211 ## flink-python/docs/reference/pyflink.datastream/checkpoint.rst: ## @@ -81,7 +81,7 @@ The default limit of concurrently happening checkpoints: one.

Re: [PR] [FLINK-34615]Split `ExternalizedCheckpointCleanup` out of `Checkpoint… [flink]

2024-04-10 Thread via GitHub
spoon-lz commented on code in PR #24461: URL: https://github.com/apache/flink/pull/24461#discussion_r1560395390 ## flink-python/docs/reference/pyflink.datastream/checkpoint.rst: ## @@ -81,7 +81,7 @@ The default limit of concurrently happening checkpoints: one.

Re: [PR] [FLINK-34615]Split `ExternalizedCheckpointCleanup` out of `Checkpoint… [flink]

2024-04-10 Thread via GitHub
spoon-lz commented on code in PR #24461: URL: https://github.com/apache/flink/pull/24461#discussion_r1560395390 ## flink-python/docs/reference/pyflink.datastream/checkpoint.rst: ## @@ -81,7 +81,7 @@ The default limit of concurrently happening checkpoints: one.

Re: [PR] [FLINK-34615]Split `ExternalizedCheckpointCleanup` out of `Checkpoint… [flink]

2024-04-10 Thread via GitHub
masteryhx commented on PR #24461: URL: https://github.com/apache/flink/pull/24461#issuecomment-2048809222 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

Re: [PR] [FLINK-34615]Split `ExternalizedCheckpointCleanup` out of `Checkpoint… [flink]

2024-04-10 Thread via GitHub
masteryhx commented on code in PR #24461: URL: https://github.com/apache/flink/pull/24461#discussion_r1560348981 ## flink-python/docs/reference/pyflink.datastream/checkpoint.rst: ## @@ -81,7 +81,7 @@ The default limit of concurrently happening checkpoints: one.

Re: [PR] [FLINK-34615]Split `ExternalizedCheckpointCleanup` out of `Checkpoint… [flink]

2024-04-10 Thread via GitHub
Zakelly commented on PR #24461: URL: https://github.com/apache/flink/pull/24461#issuecomment-2048808031 > @masteryhx Hi,this pr blocks another pr. Can you help me take a look? By the way, this change caused a python test error. Since I don’t have much experience in using python, I modified

Re: [PR] [FLINK-34615]Split `ExternalizedCheckpointCleanup` out of `Checkpoint… [flink]

2024-04-10 Thread via GitHub
spoon-lz commented on PR #24461: URL: https://github.com/apache/flink/pull/24461#issuecomment-2047043775 @masteryhx Hi,this pr blocks another pr. Can you help me take a look? By the way, this change caused a python test error. Since I don’t have much experience in using python, I modified

Re: [PR] [FLINK-34615]Split `ExternalizedCheckpointCleanup` out of `Checkpoint… [flink]

2024-04-02 Thread via GitHub
spoon-lz commented on PR #24461: URL: https://github.com/apache/flink/pull/24461#issuecomment-2031643286 @Zakelly @masteryhx The code has been adjusted, please help me take a look again. -- This is an automated message from the Apache Git Service. To respond to the message, please log on

Re: [PR] [FLINK-34615]Split `ExternalizedCheckpointCleanup` out of `Checkpoint… [flink]

2024-04-02 Thread via GitHub
spoon-lz commented on PR #24461: URL: https://github.com/apache/flink/pull/24461#issuecomment-2031422386 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment.

Re: [PR] [FLINK-34615]Split `ExternalizedCheckpointCleanup` out of `Checkpoint… [flink]

2024-04-02 Thread via GitHub
spoon-lz commented on PR #24461: URL: https://github.com/apache/flink/pull/24461#issuecomment-2031220990 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

Re: [PR] [FLINK-34615]Split `ExternalizedCheckpointCleanup` out of `Checkpoint… [flink]

2024-04-01 Thread via GitHub
spoon-lz commented on PR #24461: URL: https://github.com/apache/flink/pull/24461#issuecomment-2030958637 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

Re: [PR] [FLINK-34615]Split `ExternalizedCheckpointCleanup` out of `Checkpoint… [flink]

2024-03-25 Thread via GitHub
spoon-lz commented on code in PR #24461: URL: https://github.com/apache/flink/pull/24461#discussion_r1537179304 ## flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/CoordinatedSourceRescaleITCase.java: ## @@ -122,8 +121,9 @@

Re: [PR] [FLINK-34615]Split `ExternalizedCheckpointCleanup` out of `Checkpoint… [flink]

2024-03-25 Thread via GitHub
spoon-lz commented on code in PR #24461: URL: https://github.com/apache/flink/pull/24461#discussion_r1537133888 ## flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/CoordinatedSourceRescaleITCase.java: ## @@ -122,8 +121,9 @@

Re: [PR] [FLINK-34615]Split `ExternalizedCheckpointCleanup` out of `Checkpoint… [flink]

2024-03-21 Thread via GitHub
masteryhx commented on code in PR #24461: URL: https://github.com/apache/flink/pull/24461#discussion_r1535027271 ## flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/CoordinatedSourceRescaleITCase.java: ## @@ -122,8 +121,9 @@

Re: [PR] [FLINK-34615]Split `ExternalizedCheckpointCleanup` out of `Checkpoint… [flink]

2024-03-21 Thread via GitHub
masteryhx commented on code in PR #24461: URL: https://github.com/apache/flink/pull/24461#discussion_r1535027271 ## flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/CoordinatedSourceRescaleITCase.java: ## @@ -122,8 +121,9 @@

Re: [PR] [FLINK-34615]Split `ExternalizedCheckpointCleanup` out of `Checkpoint… [flink]

2024-03-21 Thread via GitHub
Zakelly commented on code in PR #24461: URL: https://github.com/apache/flink/pull/24461#discussion_r1534971391 ## flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/CoordinatedSourceRescaleITCase.java: ## @@ -122,8 +121,9 @@

Re: [PR] [FLINK-34615]Split `ExternalizedCheckpointCleanup` out of `Checkpoint… [flink]

2024-03-15 Thread via GitHub
spoon-lz commented on PR #24461: URL: https://github.com/apache/flink/pull/24461#issuecomment-1999140065 @Zakelly The code has been modified, please take a look again -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

Re: [PR] [FLINK-34615]Split `ExternalizedCheckpointCleanup` out of `Checkpoint… [flink]

2024-03-14 Thread via GitHub
spoon-lz commented on PR #24461: URL: https://github.com/apache/flink/pull/24461#issuecomment-1997040433 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment.

Re: [PR] [FLINK-34615]Split `ExternalizedCheckpointCleanup` out of `Checkpoint… [flink]

2024-03-12 Thread via GitHub
Zakelly commented on code in PR #24461: URL: https://github.com/apache/flink/pull/24461#discussion_r1521260155 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/CheckpointConfig.java: ## @@ -520,12 +521,40 @@ public void

Re: [PR] [FLINK-34615]Split `ExternalizedCheckpointCleanup` out of `Checkpoint… [flink]

2024-03-07 Thread via GitHub
spoon-lz commented on PR #24461: URL: https://github.com/apache/flink/pull/24461#issuecomment-1984923835 @Zakelly Please help me take a look at this PR to see if it meets the requirements. -- This is an automated message from the Apache Git Service. To respond to the message, please log

Re: [PR] [FLINK-34615]Split `ExternalizedCheckpointCleanup` out of `Checkpoint… [flink]

2024-03-07 Thread via GitHub
flinkbot commented on PR #24461: URL: https://github.com/apache/flink/pull/24461#issuecomment-1982873796 ## CI report: * 6c3c70c4d0fe086e8dd0e65533ff5dabb7265f7d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[PR] [FLINK-34615]Split `ExternalizedCheckpointCleanup` out of `Checkpoint… [flink]

2024-03-07 Thread via GitHub
spoon-lz opened a new pull request, #24461: URL: https://github.com/apache/flink/pull/24461 …Config` and move it to flink-core. ## What is the purpose of the change In FLIP-406 we want to merge all options from ExecutionCheckpointingOptions into CheckpointingOptions.