File tree Expand file tree Collapse file tree
sdks/java/core/src/test/java/org/apache/beam/sdk/transforms Expand file tree Collapse file tree Original file line number Diff line number Diff line change 2222import org .apache .beam .sdk .testing .PAssert ;
2323import org .apache .beam .sdk .testing .TestPipeline ;
2424import org .apache .beam .sdk .testing .TestStream ;
25- import org .apache .beam .sdk .testing .ValidatesRunner ;
2625import org .apache .beam .sdk .transforms .windowing .FixedWindows ;
2726import org .apache .beam .sdk .transforms .windowing .IntervalWindow ;
2827import org .apache .beam .sdk .transforms .windowing .Window ;
@@ -80,8 +79,13 @@ public void testMetadataPropagationAcrossShuffleParameter() {
8079 pipeline .run ();
8180 }
8281
82+ /**
83+ * Tests metadata propagation for a parameter. Note: PAssert internally introduces a GroupByKey.
84+ * This test works only with DirectRunner and runners that support metadata propagation across
85+ * GroupByKey. See {@link #testMetadataPropagationAcrossGBK} for more information.
86+ */
8387 @ Test
84- @ Category ({ ValidatesRunner . class , NeedsRunner .class } )
88+ @ Category (NeedsRunner .class )
8589 public void testMetadataPropagationParameter () {
8690 WindowedValues .WindowedValueCoder .setMetadataSupported ();
8791 PCollection <String > results =
You can’t perform that action at this time.
0 commit comments