Format code fix for SparkStreamingPipelineTranslator

tkaymak · web-flow · commit e106213aa68f · 2026-04-16T11:03:43.000+02:00
diff --git a/runners/spark/src/main/java/org/apache/beam/runners/spark/translation/SparkStreamingPortablePipelineTranslator.java b/runners/spark/src/main/java/org/apache/beam/runners/spark/translation/SparkStreamingPortablePipelineTranslator.java
@@ -330,7 +330,8 @@ private static <T> void translateFlatten(
         }
       }
       // Unify streams into a single stream.
-      unifiedStreams = context.getStreamingContext().union(JavaConverters.asScalaBuffer(dStreams).toList());
+      unifiedStreams = 
+        context.getStreamingContext().union(JavaConverters.asScalaBuffer(dStreams).toList());
     }
 
     context.pushDataset(

Original file line number	Diff line number	Diff line change
`@@ -330,7 +330,8 @@ private static <T> void translateFlatten(`
`330`	`330`	`}`
`331`	`331`	`}`
`332`	`332`	`// Unify streams into a single stream.`
`333`		`- unifiedStreams = context.getStreamingContext().union(JavaConverters.asScalaBuffer(dStreams).toList());`
	`333`	`+ unifiedStreams =`
	`334`	`+ context.getStreamingContext().union(JavaConverters.asScalaBuffer(dStreams).toList());`
`334`	`335`	`}`
`335`	`336`
`336`	`337`	`context.pushDataset(`