Skip to content

Commit a8a1dd4

Browse files
committed
Format code fix
1 parent 308f812 commit a8a1dd4

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

runners/spark/src/main/java/org/apache/beam/runners/spark/translation/SparkStreamingPortablePipelineTranslator.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -330,7 +330,8 @@ private static <T> void translateFlatten(
330330
}
331331
}
332332
// 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());
334335
}
335336

336337
context.pushDataset(

runners/spark/src/main/java/org/apache/beam/runners/spark/translation/streaming/ParDoStateUpdateFn.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,7 @@
1919

2020
import java.io.Serializable;
2121
import java.util.Collection;
22+
import java.util.Collections;
2223
import java.util.Iterator;
2324
import java.util.List;
2425
import java.util.Map;
@@ -62,7 +63,6 @@
6263
import org.checkerframework.checker.nullness.qual.Nullable;
6364
import org.slf4j.Logger;
6465
import org.slf4j.LoggerFactory;
65-
import java.util.Collections;
6666
import scala.Option;
6767
import scala.Tuple2;
6868
import scala.runtime.AbstractFunction3;

0 commit comments

Comments
 (0)