This is an automated email from the ASF dual-hosted git repository.

stankiewicz pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 9a6734bbe27 Fix PreCommit Java PVR Prism Loopback workflow (#38431)
9a6734bbe27 is described below

commit 9a6734bbe27910ee3d9a10006cba33813b938126
Author: Shunping Huang <[email protected]>
AuthorDate: Mon May 11 04:35:16 2026 -0400

    Fix PreCommit Java PVR Prism Loopback workflow (#38431)
    
    * Remove ValidatesRunner from testMetadataPropagationParameter
---
 .../org/apache/beam/sdk/transforms/MetadataPropagationTest.java   | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git 
a/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/MetadataPropagationTest.java
 
b/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/MetadataPropagationTest.java
index 72f914caf31..3e5ff77cb1c 100644
--- 
a/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/MetadataPropagationTest.java
+++ 
b/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/MetadataPropagationTest.java
@@ -22,7 +22,6 @@ import org.apache.beam.sdk.testing.NeedsRunner;
 import org.apache.beam.sdk.testing.PAssert;
 import org.apache.beam.sdk.testing.TestPipeline;
 import org.apache.beam.sdk.testing.TestStream;
-import org.apache.beam.sdk.testing.ValidatesRunner;
 import org.apache.beam.sdk.transforms.windowing.FixedWindows;
 import org.apache.beam.sdk.transforms.windowing.IntervalWindow;
 import org.apache.beam.sdk.transforms.windowing.Window;
@@ -80,8 +79,13 @@ public class MetadataPropagationTest {
     pipeline.run();
   }
 
+  /**
+   * Tests metadata propagation for a parameter. Note: PAssert internally 
introduces a GroupByKey.
+   * This test works only with DirectRunner and runners that support metadata 
propagation across
+   * GroupByKey. See {@link #testMetadataPropagationAcrossGBK} for more 
information.
+   */
   @Test
-  @Category({ValidatesRunner.class, NeedsRunner.class})
+  @Category(NeedsRunner.class)
   public void testMetadataPropagationParameter() {
     WindowedValues.WindowedValueCoder.setMetadataSupported();
     PCollection<String> results =

Reply via email to