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 16084c569f917..bab83a84e7a18 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; }