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);

Reply via email to