Skip to content

Commit

Permalink
Update hack to make Spark runner happy as well. (#31184)
Browse files Browse the repository at this point in the history
Both input and materializationInput are the same logical PCollection,
but the Spark test is sensitive to which one is used.
  • Loading branch information
robertwb authored May 4, 2024
1 parent e64c359 commit c531f89
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -298,7 +298,7 @@ private PCollectionView<List<T>> expandWithoutRandomAccess(PCollection<T> input)
materializationInput,
(TypeDescriptorSupplier<T>) inputCoder::getEncodedTypeDescriptor,
materializationInput.getWindowingStrategy());
input.apply(CreatePCollectionView.of(view));
materializationInput.apply(CreatePCollectionView.of(view));
return view;
}

Expand Down

0 comments on commit c531f89

Please sign in to comment.