You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by za...@apache.org on 2024/07/11 02:30:45 UTC
(flink) branch release-1.20 updated: [FLINK-35803][checkpoint] Fix the wrong file reuse in cp file-merging (#25070)
This is an automated email from the ASF dual-hosted git repository.
zakelly pushed a commit to branch release-1.20
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.20 by this push:
new 2309ab319dc [FLINK-35803][checkpoint] Fix the wrong file reuse in cp file-merging (#25070)
2309ab319dc is described below
commit 2309ab319dc273fd10270ceefe44e766ad43e893
Author: Zakelly <za...@gmail.com>
AuthorDate: Thu Jul 11 10:30:37 2024 +0800
[FLINK-35803][checkpoint] Fix the wrong file reuse in cp file-merging (#25070)
---
.../org/apache/flink/runtime/checkpoint/filemerging/PhysicalFile.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/PhysicalFile.java b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/PhysicalFile.java
index 6f3f1b55b75..5e68ca87322 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/PhysicalFile.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/PhysicalFile.java
@@ -121,7 +121,7 @@ public class PhysicalFile {
this.scope = scope;
this.size = new AtomicLong(0);
this.dataSize = new AtomicLong(0);
- this.couldReuse = true;
+ this.couldReuse = owned;
this.logicalFileRefCount = new AtomicInteger(0);
this.isOwned = owned;
}