beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <>
Subject [jira] [Work logged] (BEAM-3409) Unexpected behavior of DoFn teardown method running in unit tests
Date Thu, 15 Mar 2018 06:10:00 GMT


ASF GitHub Bot logged work on BEAM-3409:

                Author: ASF GitHub Bot
            Created on: 15/Mar/18 06:09
            Start Date: 15/Mar/18 06:09
    Worklog Time Spent: 10m 
      Work Description: rmannibucau commented on issue #4790: [BEAM-3409] waitUntilFinish()
doesn't wait for the teardown execution on Direct runner - fixing compilation issue on flink
   R: @jbonofre 

This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:

Issue Time Tracking

    Worklog Id:     (was: 80734)
    Time Spent: 5h 20m  (was: 5h 10m)

> Unexpected behavior of DoFn teardown method running in unit tests 
> ------------------------------------------------------------------
>                 Key: BEAM-3409
>                 URL:
>             Project: Beam
>          Issue Type: Bug
>          Components: runner-direct
>    Affects Versions: 2.3.0
>            Reporter: Alexey Romanenko
>            Assignee: Romain Manni-Bucau
>            Priority: Blocker
>              Labels: test
>             Fix For: 2.5.0
>          Time Spent: 5h 20m
>  Remaining Estimate: 0h
> 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()
> - run with junit

This message was sent by Atlassian JIRA

View raw message