[ 
https://issues.apache.org/jira/browse/BEAM-9187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241177#comment-17241177
 ] 

Brian Hulette commented on BEAM-9187:
-------------------------------------

I'm able to reproduce this pretty reliably on an n1-standard-1 GCP VM (I 
happened to be testing on one for a completely different purpose). I have to 
run the full {{:runners:java-fn-execution:test}} task for it to happen. I 
haven't seen it fail when running loadBalancesBundles alone.

It seems that, in the error case, what's happening is as soon as the forked 
thread releases the semaphore 
[here|https://github.com/apache/beam/blob/5e9237cd425da92a98536ba598a6217c21b31286/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/DefaultJobBundleFactory.java#L560],
 the main thread continues, [creating the 
bundle|https://github.com/apache/beam/blob/5e9237cd425da92a98536ba598a6217c21b31286/runners/java-fn-execution/src/test/java/org/apache/beam/runners/fnexecution/control/DefaultJobBundleFactoryTest.java#L478],
 and then making the assertions. However since we left the forked thread, it 
never got out of the b2.close() call and [set the 
boolean|https://github.com/apache/beam/blob/5e9237cd425da92a98536ba598a6217c21b31286/runners/java-fn-execution/src/test/java/org/apache/beam/runners/fnexecution/control/DefaultJobBundleFactoryTest.java#L470].


> org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactoryTest.loadBalancesBundles
>  is flaky
> ----------------------------------------------------------------------------------------------------
>
>                 Key: BEAM-9187
>                 URL: https://issues.apache.org/jira/browse/BEAM-9187
>             Project: Beam
>          Issue Type: Test
>          Components: runner-core
>            Reporter: Etienne Chauchot
>            Priority: P1
>              Labels: flake, flaky-test
>
> [org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactoryTest.loadBalancesBundles|https://builds.apache.org/job/beam_PreCommit_Java_Commit/9730/testReport/junit/org.apache.beam.runners.fnexecution.control/DefaultJobBundleFactoryTest/loadBalancesBundles/]
>  UTest seem to be flaky: 
> [https://builds.apache.org/job/beam_PreCommit_Java_Commit/9730/testReport/junit/org.apache.beam.runners.fnexecution.control/DefaultJobBundleFactoryTest/loadBalancesBundles/]
>  
> I have runner-core as tag but in reality this test is in 
> org.apache.beam.runners.fnexecution.control but there is no corresponding tag



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to