Skip to content

Commit 74a1cb1

Browse files
committed
Removed unused code
1 parent df3ee42 commit 74a1cb1

File tree

1 file changed

+0
-22
lines changed

1 file changed

+0
-22
lines changed

flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/FlinkUtils.java

Lines changed: 0 additions & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -403,28 +403,6 @@ public static Long calculateClusterMemoryUsage(Configuration conf, int taskManag
403403
return tmTotalMemory + jmTotalMemory;
404404
}
405405

406-
public static Long calculateClusterStateSize(Configuration conf, int taskManagerReplicas) {
407-
var clusterSpec = new KubernetesClusterClientFactory().getClusterSpecification(conf);
408-
409-
var jmParameters = new KubernetesJobManagerParameters(conf, clusterSpec);
410-
var jmTotalMemory =
411-
Math.round(
412-
jmParameters.getJobManagerMemoryMB()
413-
* Math.pow(1024, 2)
414-
* jmParameters.getJobManagerMemoryLimitFactor()
415-
* jmParameters.getReplicas());
416-
417-
var tmTotalMemory =
418-
Math.round(
419-
clusterSpec.getTaskManagerMemoryMB()
420-
* Math.pow(1024, 2)
421-
* conf.getDouble(
422-
KubernetesConfigOptions.TASK_MANAGER_MEMORY_LIMIT_FACTOR)
423-
* taskManagerReplicas);
424-
425-
return tmTotalMemory + jmTotalMemory;
426-
}
427-
428406
public static void setGenerationAnnotation(Configuration conf, Long generation) {
429407
if (generation == null) {
430408
return;

0 commit comments

Comments
 (0)