Thank you. How does one use the BlockingDataflowPipelineRunner with Beam?
Specifying it in the PipelineOptions results in an Exception with a
message stating that it is not one of the supported pipeline runners:
"Exception in thread "main" java.lang.IllegalArgumentException: Class
'com.google.cloud.dataflow.sdk.runners.BlockingDataflowPipelineRunner'
does not implement PipelineRunner. Supported pipeline runners
[DataflowRunner, DirectRunner, FlinkRunner, TestFlinkRunner]"
On 23. jan. 2017 22:31, Lukasz Cwik wrote:
Please take a look at
https://cloud.google.com/dataflow/pipelines/logging#monitoring-pipeline-logs
On Mon, Jan 23, 2017 at 12:21 PM, Gareth Western
<[email protected] <mailto:[email protected]>> wrote:
I'm having trouble running my pipeline using the dataflow runner.
The job is submitted successfully:
Dataflow SDK version: 0.4.0
Submitted job: 2017-01-23_12_17_20-13351949104581541182
but in the Dataflow console it simply says " workflow failed". I
can't seem to find any more details regarding the cause of the
failure. Where should I be looking?
