This is an automated email from the ASF dual-hosted git repository. zakelly pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push: new 91aecc62f3c [hotfix][runtime] Fix typo in methods/parameters naming for ResourceProfileInfo.java (#26820) 91aecc62f3c is described below commit 91aecc62f3c83956af4b3554f31ee2bbce057be7 Author: Yuepeng Pan <panyuep...@apache.org> AuthorDate: Tue Jul 29 10:39:53 2025 +0800 [hotfix][runtime] Fix typo in methods/parameters naming for ResourceProfileInfo.java (#26820) --- .../flink/runtime/rest/messages/ResourceProfileInfo.java | 10 +++++----- .../flink/runtime/rest/messages/taskmanager/SlotInfo.java | 2 +- .../runtime/rest/messages/taskmanager/TaskManagerInfo.java | 4 ++-- 3 files changed, 8 insertions(+), 8 deletions(-) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/ResourceProfileInfo.java b/flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/ResourceProfileInfo.java index 57645577040..d3091182ded 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/ResourceProfileInfo.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/ResourceProfileInfo.java @@ -89,22 +89,22 @@ public class ResourceProfileInfo implements ResponseBody, Serializable { resourceProfile.getTaskOffHeapMemory().getMebiBytes(), resourceProfile.getManagedMemory().getMebiBytes(), resourceProfile.getNetworkMemory().getMebiBytes(), - getExetendedResources(resourceProfile.getExtendedResources())); + getExtendedResources(resourceProfile.getExtendedResources())); } private ResourceProfileInfo() { this(-1.0, -1, -1, -1, -1, Collections.emptyMap()); } - public static ResourceProfileInfo fromResrouceProfile(ResourceProfile resourceProfile) { + public static ResourceProfileInfo fromResourceProfile(ResourceProfile resourceProfile) { return resourceProfile.equals(ResourceProfile.UNKNOWN) ? new ResourceProfileInfo() : new ResourceProfileInfo(resourceProfile); } - private static Map<String, Double> getExetendedResources( - Map<String, ExternalResource> exetendedResources) { - return exetendedResources.entrySet().stream() + private static Map<String, Double> getExtendedResources( + Map<String, ExternalResource> extendedResources) { + return extendedResources.entrySet().stream() .collect( Collectors.toMap( Map.Entry::getKey, e -> e.getValue().getValue().doubleValue())); diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/SlotInfo.java b/flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/SlotInfo.java index f99167b5e5b..6da1b4e8004 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/SlotInfo.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/SlotInfo.java @@ -63,7 +63,7 @@ public class SlotInfo implements ResponseBody, Serializable { } public SlotInfo(JobID jobId, ResourceProfile resource) { - this(jobId, ResourceProfileInfo.fromResrouceProfile(resource)); + this(jobId, ResourceProfileInfo.fromResourceProfile(resource)); } @JsonIgnore diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagerInfo.java b/flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagerInfo.java index 308e49b504d..cca037e2aa6 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagerInfo.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagerInfo.java @@ -161,8 +161,8 @@ public class TaskManagerInfo implements ResponseBody, Serializable { lastHeartbeat, numberSlots, numberAvailableSlots, - ResourceProfileInfo.fromResrouceProfile(totalResource), - ResourceProfileInfo.fromResrouceProfile(freeResource), + ResourceProfileInfo.fromResourceProfile(totalResource), + ResourceProfileInfo.fromResourceProfile(freeResource), hardwareDescription, memoryConfiguration, blocked);