Skip to content
Closed
Show file tree
Hide file tree
Changes from 2 commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -2,5 +2,6 @@
"https://github.com/apache/beam/pull/34902": "Introducing OutputBuilder",
"comment": "Modify this file in a trivial way to cause this test suite to run",
"https://github.com/apache/beam/pull/31156": "noting that PR #31156 should run this test",
"https://github.com/apache/beam/pull/35159": "moving WindowedValue and making an interface"
"https://github.com/apache/beam/pull/35159": "moving WindowedValue and making an interface",
"https://github.com/apache/beam/pull/38437" : "Fix ULR metadata propagation test flake"
}
Original file line number Diff line number Diff line change
Expand Up @@ -83,6 +83,7 @@ public void testMetadataPropagationAcrossShuffleParameter() {
@Test
@Category({ValidatesRunner.class, NeedsRunner.class})
Comment thread
aIbrahiim marked this conversation as resolved.
Outdated
public void testMetadataPropagationParameter() {
WindowedValues.WindowedValueCoder.setMetadataSupported();
Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

high

The class name WindowedValues appears to be a typo for WindowedValue. This will likely cause a compilation error as the standard Beam class is WindowedValue.

Suggested change
WindowedValues.WindowedValueCoder.setMetadataSupported();
WindowedValue.WindowedValueCoder.setMetadataSupported();

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

high

Setting global static state within a ValidatesRunner test can lead to test interference and flakes in other tests. Since this test is part of a suite that may run in parallel or in a shared JVM, consider using a setup/teardown mechanism (like @Before and @After) to ensure the state is properly initialized and reset, maintaining test isolation.

PCollection<String> results =
pipeline
.apply(Create.of(true))
Expand Down
Loading