[hotfix][runtime] Fix the missing arguments in error message in Memor…

…yManager and FsCheckpointStorageAccess
ndeslandes · Jan 25, 2021 · 33c14a1 · 33c14a1
1 parent d20867a
commit 33c14a1
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/memory/MemoryManager.java b/flink-runtime/src/main/java/org/apache/flink/runtime/memory/MemoryManager.java
@@ -218,7 +218,7 @@ public void allocatePages(Object owner, Collection<MemorySegment> target, int nu
         Preconditions.checkState(!isShutDown, "Memory manager has been shut down.");
         Preconditions.checkArgument(
                 numberOfPages <= totalNumberOfPages,
-                "Cannot allocate more segments %d than the max number %d",
+                "Cannot allocate more segments %s than the max number %s",
                 numberOfPages,
                 totalNumberOfPages);
 

diff --git a/...me/src/main/java/org/apache/flink/runtime/state/filesystem/FsCheckpointStorageAccess.java b/...me/src/main/java/org/apache/flink/runtime/state/filesystem/FsCheckpointStorageAccess.java
@@ -118,7 +118,7 @@ public void initializeBaseLocations() throws IOException {
     @Override
     public CheckpointStorageLocation initializeLocationForCheckpoint(long checkpointId)
             throws IOException {
-        checkArgument(checkpointId >= 0, "Illegal negative checkpoint id: %d.", checkpointId);
+        checkArgument(checkpointId >= 0, "Illegal negative checkpoint id: %s.", checkpointId);
         checkArgument(
                 baseLocationsInitialized, "The base checkpoint location has not been initialized.");