From c531f898d6b3454761f78a2420df5424178fb002 Mon Sep 17 00:00:00 2001 From: Robert Bradshaw Date: Sat, 4 May 2024 05:58:40 -0700 Subject: [PATCH] Update hack to make Spark runner happy as well. (#31184) Both input and materializationInput are the same logical PCollection, but the Spark test is sensitive to which one is used. --- .../core/src/main/java/org/apache/beam/sdk/transforms/View.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/View.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/View.java index 16084c569f91..bab83a84e7a1 100644 --- a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/View.java +++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/View.java @@ -298,7 +298,7 @@ private PCollectionView> expandWithoutRandomAccess(PCollection input) materializationInput, (TypeDescriptorSupplier) inputCoder::getEncodedTypeDescriptor, materializationInput.getWindowingStrategy()); - input.apply(CreatePCollectionView.of(view)); + materializationInput.apply(CreatePCollectionView.of(view)); return view; }