Zakelly closed pull request #24640: [FLINK-32080][FLIP-306][checkpoint]
Restoration of FileMergingSnapshotManager
URL: https://github.com/apache/flink/pull/24640
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abo
ljz2051 commented on code in PR #24640:
URL: https://github.com/apache/flink/pull/24640#discussion_r1584382431
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/FileMergingSnapshotManagerBase.java:
##
@@ -575,8 +576,51 @@ private void createManagedDi
ljz2051 commented on code in PR #24640:
URL: https://github.com/apache/flink/pull/24640#discussion_r1584375937
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/FileMergingSnapshotManagerBase.java:
##
@@ -575,8 +576,51 @@ private void createManagedDi
ljz2051 commented on code in PR #24640:
URL: https://github.com/apache/flink/pull/24640#discussion_r1584364578
##
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java:
##
@@ -830,6 +832,8 @@ public CompletableFuture submitTask(
ljz2051 commented on code in PR #24640:
URL: https://github.com/apache/flink/pull/24640#discussion_r1584361582
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/FileMergingSnapshotManagerBase.java:
##
@@ -575,8 +576,51 @@ private void createManagedDi
fredia commented on code in PR #24640:
URL: https://github.com/apache/flink/pull/24640#discussion_r1582077221
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/FileMergingSnapshotManagerBase.java:
##
@@ -575,8 +576,51 @@ private void createManagedDir
ljz2051 commented on code in PR #24640:
URL: https://github.com/apache/flink/pull/24640#discussion_r1579435004
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/FileMergingSnapshotManagerBase.java:
##
@@ -575,8 +576,51 @@ private void createManagedDi
ljz2051 commented on code in PR #24640:
URL: https://github.com/apache/flink/pull/24640#discussion_r1579435004
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/FileMergingSnapshotManagerBase.java:
##
@@ -575,8 +576,51 @@ private void createManagedDi
Zakelly commented on code in PR #24640:
URL: https://github.com/apache/flink/pull/24640#discussion_r1574334314
##
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java:
##
@@ -830,6 +832,8 @@ public CompletableFuture submitTask(
ljz2051 commented on code in PR #24640:
URL: https://github.com/apache/flink/pull/24640#discussion_r1562174418
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/FileMergingSnapshotManagerBase.java:
##
@@ -547,4 +548,43 @@ private void createManagedDi
Zakelly commented on code in PR #24640:
URL: https://github.com/apache/flink/pull/24640#discussion_r1560731003
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/FileMergingSnapshotManagerBase.java:
##
@@ -547,4 +548,43 @@ private void createManagedDi
fredia commented on code in PR #24640:
URL: https://github.com/apache/flink/pull/24640#discussion_r1557536559
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/FileMergingSnapshotManagerBase.java:
##
@@ -547,4 +548,43 @@ private void createManagedDir
ljz2051 commented on PR #24640:
URL: https://github.com/apache/flink/pull/24640#issuecomment-2044605255
@Zakelly @fredia @masteryhx Could you please take a look ?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
UR
flinkbot commented on PR #24640:
URL: https://github.com/apache/flink/pull/24640#issuecomment-2044601959
## CI report:
* 475bd17770242252ed449148afe8d4021f833176 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
ljz2051 opened a new pull request, #24640:
URL: https://github.com/apache/flink/pull/24640
## What is the purpose of the change
This pull request introduces the restoration mechanism for
FileMergingSnapshotManager. See FLIP-306 for more information.
## Brief change log
15 matches
Mail list logo