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 cba13ecb6bf2..72f914caf31e 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 void testMetadataPropagationAcrossShuffleParameter() { @Test @Category({ValidatesRunner.class, NeedsRunner.class}) public void testMetadataPropagationParameter() { + WindowedValues.WindowedValueCoder.setMetadataSupported(); PCollection results = pipeline .apply(Create.of(true))