diff --git a/runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkStreamingTransformTranslators.java b/runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkStreamingTransformTranslators.java
index 15bc0e0f71a1..4e94d6957a63 100644
--- a/runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkStreamingTransformTranslators.java
+++ b/runners/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);