commit c531f898d6b3454761f78a2420df5424178fb002
author Robert Bradshaw <robertwb@gmail.com> Sat May 04 05:58:40 2024 -0700
committer GitHub <noreply@github.com> Sat May 04 08:58:40 2024 -0400
tree 64a590e7ce4c7071db6e09253bc04b34530daff7
parent e64c3596253c80ade845bf8765e6f7e04b8c57f1

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.

sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/View.java

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 16084c5..bab83a8 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 @@
               materializationInput,
               (TypeDescriptorSupplier<T>) inputCoder::getEncodedTypeDescriptor,
               materializationInput.getWindowingStrategy());
-      input.apply(CreatePCollectionView.of(view));
+      materializationInput.apply(CreatePCollectionView.of(view));
       return view;
     }