You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ma...@apache.org on 2022/03/18 06:27:36 UTC
[flink] 02/02: [hotfix][runtime] Makes use of static variable
This is an automated email from the ASF dual-hosted git repository.
mapohl pushed a commit to branch release-1.15
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 604668e0ca3fbac43eb921f2bc80c07e28e7859f
Author: Matthias Pohl <ma...@ververica.com>
AuthorDate: Thu Mar 17 09:49:31 2022 +0100
[hotfix][runtime] Makes use of static variable
---
.../apache/flink/runtime/highavailability/FileSystemJobResultStore.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/FileSystemJobResultStore.java b/flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/FileSystemJobResultStore.java
index 5c19c2e..5f05180 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/FileSystemJobResultStore.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/FileSystemJobResultStore.java
@@ -125,7 +125,7 @@ public class FileSystemJobResultStore extends AbstractThreadsafeJobResultStore {
* @return A path for a clean entry for the given the Job ID.
*/
private Path constructCleanPath(JobID jobId) {
- return constructEntryPath(jobId.toString() + ".json");
+ return constructEntryPath(jobId.toString() + FILE_EXTENSION);
}
@VisibleForTesting