From 1f3425d240169ac8b2c81fea64710f9c5d0feea9 Mon Sep 17 00:00:00 2001
From: Max Michels <max_michels@apple.com>
Date: Thu, 22 Feb 2024 17:59:04 +0100
Subject: [PATCH] fixup! Remove testing code

---
 .../org/apache/flink/autoscaler/JobAutoScalerImpl.java    | 8 +-------
 1 file changed, 1 insertion(+), 7 deletions(-)

diff --git a/flink-autoscaler/src/main/java/org/apache/flink/autoscaler/JobAutoScalerImpl.java b/flink-autoscaler/src/main/java/org/apache/flink/autoscaler/JobAutoScalerImpl.java
index 8d0fbf4cf0..cc56eb3e69 100644
--- a/flink-autoscaler/src/main/java/org/apache/flink/autoscaler/JobAutoScalerImpl.java
+++ b/flink-autoscaler/src/main/java/org/apache/flink/autoscaler/JobAutoScalerImpl.java
@@ -26,7 +26,6 @@
 import org.apache.flink.autoscaler.metrics.EvaluatedMetrics;
 import org.apache.flink.autoscaler.realizer.ScalingRealizer;
 import org.apache.flink.autoscaler.state.AutoScalerStateStore;
-import org.apache.flink.autoscaler.topology.JobTopology;
 import org.apache.flink.autoscaler.tuning.ConfigChanges;
 import org.apache.flink.configuration.PipelineOptions;
 import org.apache.flink.util.Preconditions;
@@ -217,12 +216,7 @@ private void runScalingLogic(Context ctx, AutoscalerFlinkMetrics autoscalerMetri
 
         var parallelismChanged =
                 scalingExecutor.scaleResource(
-                        ctx,
-                        evaluatedMetrics,
-                        scalingHistory,
-                        scalingTracking,
-                        now,
-                        new JobTopology());
+                        ctx, evaluatedMetrics, scalingHistory, scalingTracking, now, jobTopology);
 
         if (parallelismChanged) {
             autoscalerMetrics.incrementScaling();