You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by vt...@apache.org on 2026/05/08 12:56:00 UTC
(beam) branch fix-metadata created (now 8385c88c094)
This is an automated email from the ASF dual-hosted git repository.
Amar3tto pushed a change to branch fix-metadata
in repository https://gitbox.apache.org/repos/asf/beam.git
at 8385c88c094 Fix test
This branch includes the following new commits:
new 8385c88c094 Fix test
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
(beam) 01/01: Fix test
Posted by vt...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
Amar3tto pushed a commit to branch fix-metadata
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 8385c88c0940fb9d8a7afd7268ce2a06318bad26
Author: Vitaly Terentyev <vi...@akvelon.com>
AuthorDate: Fri May 8 16:55:46 2026 +0400
Fix test
---
.../java/org/apache/beam/sdk/transforms/MetadataPropagationTest.java | 1 +
1 file changed, 1 insertion(+)
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 cba13ecb6bf..72f914caf31 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
@@ -83,6 +83,7 @@ public class MetadataPropagationTest {
@Test
@Category({ValidatesRunner.class, NeedsRunner.class})
public void testMetadataPropagationParameter() {
+ WindowedValues.WindowedValueCoder.setMetadataSupported();
PCollection<String> results =
pipeline
.apply(Create.of(true))