谷歌雲數據流上的Apache梁

我試圖在谷歌雲數據流上運行一項工作，但無法使部署工作。作業運行正常使用DirectRunner但只要我切換到數據流亞軍我得到以下異常：谷歌雲數據流上的Apache梁

[WARNING] 
java.lang.reflect.InvocationTargetException 
     at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) 
     at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) 
     at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) 
     at java.lang.reflect.Method.invoke(Method.java:498) 
     at org.codehaus.mojo.exec.ExecJavaMojo$1.run(ExecJavaMojo.java:293) 
     at java.lang.Thread.run(Thread.java:745) 
Caused by: java.lang.IllegalArgumentException: No Runner was specified and the DirectRunner was not found on the classpath. 
Specify a runner by either: 
    Explicitly specifying a runner by providing the 'runner' property 
    Adding the DirectRunner to the classpath 
    Calling 'PipelineOptions.setRunner(PipelineRunner)' directly 
     at org.apache.beam.sdk.options.PipelineOptions$DirectRunner.create(PipelineOptions.java:286) 
     at org.apache.beam.sdk.options.PipelineOptions$DirectRunner.create(PipelineOptions.java:276) 
     at org.apache.beam.sdk.options.ProxyInvocationHandler.returnDefaultHelper(ProxyInvocationHandler.java:575) 
     at org.apache.beam.sdk.options.ProxyInvocationHandler.getDefault(ProxyInvocationHandler.java:516) 
     at org.apache.beam.sdk.options.ProxyInvocationHandler.invoke(ProxyInvocationHandler.java:155) 
     at org.apache.beam.sdk.options.PipelineOptionsValidator.validate(PipelineOptionsValidator.java:70) 
     at org.apache.beam.sdk.runners.PipelineRunner.fromOptions(PipelineRunner.java:44) 
     at org.apache.beam.sdk.Pipeline.create(Pipeline.java:138) 
     at my.package.SalesTransactions.main(SalesTransactions.java:218)

我的命令來運行：

mvn compile exec:java -Dexec.mainClass=my.package.SalesTransactions -Dexec.args="--runner=DataflowRunner --project=my-project --tempLocation=gs://my-project/tmp" -Pdataflow-runner

來源

2017-04-05 Jimmy

你可以分享你的pom.xml文件，或者確認你已經添加了對Dataflow runner的依賴嗎？ –

我已經添加了一個顯示使用的maven配置文件的pom.xml提取。 – jimmy

發現我的錯誤。當從DirectRunner切換到DataFlowRunner時，我不得不在我的pom.xml中添加依賴關係，而不是將其作爲配置文件運行時依賴關係。

<dependency> 
     <groupId>org.apache.beam</groupId> 
     <artifactId>beam-runners-google-cloud-dataflow-java</artifactId> 
     <version>${beam.version}</version> 
    </dependency>

來源

2017-04-06 14:10:30 Jimmy

谷歌雲數據流上的Apache梁

回答

相關問題