[
https://issues.apache.org/jira/browse/BEAM-3409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16316634#comment-16316634
]
Romain Manni-Bucau commented on BEAM-3409:
------------------------------------------
Hi
started to hack on that in
https://github.com/rmannibucau/incubator-beam/tree/fix/BEAM-3409_wait-for-teardown-execution-in-direct-runner
still need some enhancements to have all tests passing but guess the issue is
at least identified
> Unexpected behavior of DoFn teardown method running in unit tests
> ------------------------------------------------------------------
>
> Key: BEAM-3409
> URL: https://issues.apache.org/jira/browse/BEAM-3409
> Project: Beam
> Issue Type: Bug
> Components: runner-direct, testing
> Affects Versions: 2.3.0
> Reporter: Alexey Romanenko
> Assignee: Jean-Baptiste Onofré
> Priority: Minor
> Labels: test
>
> Writing a unit test, I found out a strange behaviour of Teardown method of
> DoFn implementation when I run this method in unit tests using TestPipeline.
> To be more precise, it doesn’t wait until teardown() method will be finished,
> it just exits from this method after about 1 sec (on my machine) even if it
> should take longer (very simple example - running infinite loop inside this
> method or put thread in sleep). In the same time, when I run the same code
> from main() with ordinary Pipeline and direct runner, then it’s ok and it
> works as expected - teardown() method will be performed completely despite
> how much time it will take.
> I created two test cases to reproduce this issue - the first one to run with
> main() and the second one to run with junit. They use the same implementation
> of DoFn (class LongTearDownFn) and expects that teardown method will be
> running at least for SLEEP_TIME ms. In case of running as junit test it's not
> a case (see output log).
> - run with main()
> https://github.com/aromanenko-dev/beam-samples/blob/master/runners-tests/src/main/java/TearDown.java
> - run with junit
> https://github.com/aromanenko-dev/beam-samples/blob/master/runners-tests/src/test/java/TearDownTest.java
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
