label value as long

apache · Jan 22, 2024 · 16029cf · 16029cf
1 parent 61da1dd
commit 16029cf
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...ker/src/test/java/org/apache/beam/runners/dataflow/worker/DataflowWorkUnitClientTest.java b/...ker/src/test/java/org/apache/beam/runners/dataflow/worker/DataflowWorkUnitClientTest.java
@@ -243,10 +243,10 @@ public void testReportWorkerMessage() throws Exception {
         new StreamingScalingReport()
             .setActiveThreadCount(1)
             .setActiveBundleCount(2)
-            .setOutstandingBytes(3)
+            .setOutstandingBytes(3L)
             .setMaximumThreadCount(4)
             .setMaximumBundleCount(5)
-            .setMaximumBytes(6);
+            .setMaximumBytes(6L);
     WorkUnitClient client = new DataflowWorkUnitClient(pipelineOptions, LOG);
     WorkerMessage msg = client.createWorkerMessageFromStreamingScalingReport(activeThreadsReport);
     client.reportWorkerMessage(msg);