From 2d559ba8dff5ef363e8bbebb9b18cf0a299de041 Mon Sep 17 00:00:00 2001 From: chuixue Date: Thu, 22 Apr 2021 17:45:19 +0800 Subject: [PATCH] [FLINK-22409][runtime]Rename ResourceProfile class throwUnsupportedOperationExecptionIfUnknown method --- .../types/ResourceProfile.java | 20 +++++++++---------- 1 file changed, 10 insertions(+), 10 deletions(-) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/ResourceProfile.java b/flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/ResourceProfile.java index f0990272730e3..942244cc84cb7 100755 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/ResourceProfile.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/ResourceProfile.java @@ -174,7 +174,7 @@ private ResourceProfile() { * @return The cpu cores, 1.0 means a full cpu thread */ public CPUResource getCpuCores() { - throwUnsupportedOperationExecptionIfUnknown(); + throwUnsupportedOperationExceptionIfUnknown(); return cpuCores; } @@ -184,7 +184,7 @@ public CPUResource getCpuCores() { * @return The task heap memory */ public MemorySize getTaskHeapMemory() { - throwUnsupportedOperationExecptionIfUnknown(); + throwUnsupportedOperationExceptionIfUnknown(); return taskHeapMemory; } @@ -194,7 +194,7 @@ public MemorySize getTaskHeapMemory() { * @return The task off-heap memory */ public MemorySize getTaskOffHeapMemory() { - throwUnsupportedOperationExecptionIfUnknown(); + throwUnsupportedOperationExceptionIfUnknown(); return taskOffHeapMemory; } @@ -204,7 +204,7 @@ public MemorySize getTaskOffHeapMemory() { * @return The managed memory */ public MemorySize getManagedMemory() { - throwUnsupportedOperationExecptionIfUnknown(); + throwUnsupportedOperationExceptionIfUnknown(); return managedMemory; } @@ -214,7 +214,7 @@ public MemorySize getManagedMemory() { * @return The network memory */ public MemorySize getNetworkMemory() { - throwUnsupportedOperationExecptionIfUnknown(); + throwUnsupportedOperationExceptionIfUnknown(); return networkMemory; } @@ -224,7 +224,7 @@ public MemorySize getNetworkMemory() { * @return The total memory */ public MemorySize getTotalMemory() { - throwUnsupportedOperationExecptionIfUnknown(); + throwUnsupportedOperationExceptionIfUnknown(); return getOperatorsMemory().add(networkMemory); } @@ -234,7 +234,7 @@ public MemorySize getTotalMemory() { * @return The operator memory */ public MemorySize getOperatorsMemory() { - throwUnsupportedOperationExecptionIfUnknown(); + throwUnsupportedOperationExceptionIfUnknown(); return taskHeapMemory.add(taskOffHeapMemory).add(managedMemory); } @@ -244,11 +244,11 @@ public MemorySize getOperatorsMemory() { * @return The extended resources */ public Map getExtendedResources() { - throwUnsupportedOperationExecptionIfUnknown(); + throwUnsupportedOperationExceptionIfUnknown(); return Collections.unmodifiableMap(extendedResources); } - private void throwUnsupportedOperationExecptionIfUnknown() { + private void throwUnsupportedOperationExceptionIfUnknown() { if (this.equals(UNKNOWN)) { throw new UnsupportedOperationException(); } @@ -262,7 +262,7 @@ private void throwUnsupportedOperationExecptionIfUnknown() { */ public boolean isMatching(final ResourceProfile required) { checkNotNull(required, "Cannot check matching with null resources"); - throwUnsupportedOperationExecptionIfUnknown(); + throwUnsupportedOperationExceptionIfUnknown(); if (this.equals(ANY)) { return true;