Fix compilation errors

jto · Oct 25, 2023 · dd62a77 · dd62a77
1 parent 045271c
commit dd62a77
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...flink/src/main/java/org/apache/beam/runners/flink/FlinkStreamingTransformTranslators.java b/...flink/src/main/java/org/apache/beam/runners/flink/FlinkStreamingTransformTranslators.java
@@ -223,7 +223,7 @@ public void translateNode(
                 ? context.getExecutionEnvironment().getMaxParallelism()
                 : context.getExecutionEnvironment().getParallelism();
 
-        FlinkUnboundedSource<T> unboundedSource = FlinkSource.unbounded(
+        FlinkUnboundedSource<T> unboundedSource = FlinkSource.unbounded(transform.getName(),
             rawSource, new SerializablePipelineOptions(context.getPipelineOptions()), parallelism);
         nonDedupSource =
             context
@@ -376,6 +376,7 @@ public void translateNode(
               : context.getExecutionEnvironment().getParallelism();
 
       FlinkBoundedSource<T> flinkBoundedSource = FlinkSource.bounded(
+          transform.getName(),
           rawSource,
           new SerializablePipelineOptions(context.getPipelineOptions()),
           parallelism);