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 =