Fix compilation errors (#874)

Co-authored-by: Vaibhav Maheshwari <vmaheshw@vmaheshw-mn1.linkedin.biz>
linkedin · Dec 1, 2021 · b838a4b · b838a4b
1 parent 065450e
commit b838a4b
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...-server/src/test/java/com/linkedin/datastream/server/TestLoadBasedTaskCountEstimator.java b/...-server/src/test/java/com/linkedin/datastream/server/TestLoadBasedTaskCountEstimator.java
@@ -106,8 +106,8 @@ public void throughputTaskEstimatorWithTopicLevelInformation() {
     List<String> assignedPartitions = Collections.emptyList();
     List<String> unassignedPartitions = Arrays.asList("apple-0", "apple-1", "apple-2", "banana-0");
     LoadBasedTaskCountEstimator estimator = new LoadBasedTaskCountEstimator(TASK_CAPACITY_MBPS,
-        TASK_CAPACITY_UTILIZATION_PCT);
-    int taskCount = estimator.getTaskCount(throughputInfo, assignedPartitions, unassignedPartitions);
+        TASK_CAPACITY_UTILIZATION_PCT, DEFAULT_BYTES_IN_KB_RATE, DEFAULT_MSGS_IN_RATE);
+    int taskCount = estimator.getTaskCount(throughputInfo, assignedPartitions, unassignedPartitions, "test");
     Assert.assertEquals(taskCount, 4);
   }
 }