[
https://issues.apache.org/jira/browse/BEAM-9164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17057128#comment-17057128
]
Tomo Suzuki edited comment on BEAM-9164 at 3/11/20, 3:41 PM:
-------------------------------------------------------------
I tried to reproduce the flakiness in my workstation by running the
{{UnboundedSourceWrapperTest}} 100 times, but could not reproduce the failure.
{noformat}
@Parameterized.Parameters(name = "numTasks = {0}; numSplits={1}")
public static Collection<Object[]> data() {
/*
* Parameters for initializing the tests:
* {numTasks, numSplits}
* The test currently assumes powers of two for some assertions.
*/
ImmutableList.Builder<Object[]> list = ImmutableList.builder();
for (int i=0; i< 100; ++i) {
list.addAll(Arrays.asList(new Object[][] {
{1, 1}, {1, 2}, {1, 4},
{2, 1}, {2, 2}, {2, 4},
{4, 1}, {4, 2}, {4, 4},
}));
}
return list.build();
}
{noformat}
Memo: what if the test is interfered by other tests? How can we verify a fix is
correct solution?
was (Author: suztomo):
I tried to reproduce the flakiness in my workstation by running the
{{UnboundedSourceWrapperTest}} 100 times, but could not reproduce the failure.
{noformat}
@Parameterized.Parameters(name = "numTasks = {0}; numSplits={1}")
public static Collection<Object[]> data() {
/*
* Parameters for initializing the tests:
* {numTasks, numSplits}
* The test currently assumes powers of two for some assertions.
*/
ImmutableList.Builder<Object[]> list = ImmutableList.builder();
for (int i=0; i< 100; ++i) {
list.addAll(Arrays.asList(new Object[][] {
{1, 1}, {1, 2}, {1, 4},
{2, 1}, {2, 2}, {2, 4},
{4, 1}, {4, 2}, {4, 4},
}));
}
return list.build();
}
{noformat}
> [PreCommit_Java] [Flake]
> org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSourceWrapperTest$ParameterizedUnboundedSourceWrapperTest
> -----------------------------------------------------------------------------------------------------------------------------------------------------------
>
> Key: BEAM-9164
> URL: https://issues.apache.org/jira/browse/BEAM-9164
> Project: Beam
> Issue Type: Improvement
> Components: runner-flink
> Reporter: Kirill Kozlov
> Priority: Major
> Labels: flake
>
> Test:
> org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSourceWrapperTest$ParameterizedUnboundedSourceWrapperTest
> >> testWatermarkEmission[numTasks = 1; numSplits=1]
> Fails with the following exception:
> {code:java}
> org.junit.runners.model.TestTimedOutException: test timed out after 30000
> milliseconds{code}
> Affected Jenkins job:
> [https://builds.apache.org/job/beam_PreCommit_Java_Phrase/1665/]
> Gradle build scan: [https://scans.gradle.com/s/nvgeb425fe63q]
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
