This is an automated email from the ASF dual-hosted git repository. jark pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 33c14a12f4332d82b1f480a44b1dc8c0e02b97c2 Author: Jark Wu <[email protected]> AuthorDate: Mon Jan 18 21:04:49 2021 +0800 [hotfix][runtime] Fix the missing arguments in error message in MemoryManager and FsCheckpointStorageAccess --- .../src/main/java/org/apache/flink/runtime/memory/MemoryManager.java | 2 +- .../flink/runtime/state/filesystem/FsCheckpointStorageAccess.java | 2 +- 2 files changed, 2 insertions(+), 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 index 2ef80fa..19c2dfd 100644 --- 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 class MemoryManager { 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/flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsCheckpointStorageAccess.java b/flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsCheckpointStorageAccess.java index 6347cc0..f1c3278 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsCheckpointStorageAccess.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsCheckpointStorageAccess.java @@ -118,7 +118,7 @@ public class FsCheckpointStorageAccess extends AbstractFsCheckpointStorageAccess @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.");
