beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Pei He (JIRA)" <>
Subject [jira] [Created] (BEAM-444) Promote isBlockOnRun() to PipelineOptions.
Date Tue, 12 Jul 2016 22:06:20 GMT
Pei He created BEAM-444:

             Summary: Promote isBlockOnRun() to PipelineOptions.
                 Key: BEAM-444
             Project: Beam
          Issue Type: New Feature
            Reporter: Pei He
            Assignee: Pei He

Currently, blockOnRun is implemented in different ways by runners.
DirectRunner did blockOnRun based on DirectOptions.isBlockOnRun.
Dataflow have a separate BlockingDataflowRunner.
Flink and Spark runners might or might not block depends on their implementation on run().

I think DirectRunner's approach is the right way to go, and isBlockOnRun options need to be
promoted to the general PipelineOptions.

This message was sent by Atlassian JIRA

View raw message