You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by az...@apache.org on 2020/02/25 09:06:18 UTC
[flink] 01/04: [hotfix] Minor clean-up in TaskExecutorProcessUtils.
This is an automated email from the ASF dual-hosted git repository.
azagrebin pushed a commit to branch release-1.10
in repository https://gitbox.apache.org/repos/asf/flink.git
commit ab3e3906c5f362a539dd7a6fe2f400dfab32a93e
Author: Xintong Song <to...@gmail.com>
AuthorDate: Mon Feb 24 19:01:46 2020 +0800
[hotfix] Minor clean-up in TaskExecutorProcessUtils.
---
.../flink/runtime/clusterframework/TaskExecutorProcessUtils.java | 8 ++------
1 file changed, 2 insertions(+), 6 deletions(-)
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/TaskExecutorProcessUtils.java b/flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/TaskExecutorProcessUtils.java
index 31b65d5..917c575 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/TaskExecutorProcessUtils.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/TaskExecutorProcessUtils.java
@@ -640,15 +640,11 @@ public class TaskExecutorProcessUtils {
}
}
- public static CPUResource getCpuCoresWithFallback(final Configuration config, double fallback) {
- return getCpuCores(config, fallback);
- }
-
private static CPUResource getCpuCores(final Configuration config) {
- return getCpuCores(config, -1.0);
+ return getCpuCoresWithFallback(config, -1.0);
}
- private static CPUResource getCpuCores(final Configuration config, double fallback) {
+ public static CPUResource getCpuCoresWithFallback(final Configuration config, double fallback) {
final double cpuCores;
if (config.contains(TaskManagerOptions.CPU_CORES)) {
cpuCores = config.getDouble(TaskManagerOptions.CPU_CORES);