MinimalWordCountを使用してMinimalWordCount - > Run as Javaアプリケーションを使用しているウィンドウでEclipseからDataFlowRunnerを使用してMinimalWordCountの例を実行しようとしています。私のgcsのバケツ、しかし、私は一貫して次の例外を取得する、いくつかの1つは私にここで何が問題を知っていることができますか?Apache Beam Eclipseでデータフローランナーを使用するMinimalWordcountの例
- バケット名が正しいことを確認しました。
- 私はすでにWindowsマシン上でgcloud initを実行しました。
java.lang.RuntimeExceptionスレッドの例外 "メイン": に失敗した組織でファクトリメソッドから DataflowRunner#1 fromOptions(インターフェース org.apache.beam.sdk.options.PipelineOptions) のインスタンスを構築します.apache.beam.sdk.util.InstanceBuilder.buildFromMethod(InstanceBuilder.java:233) at org.apache.beam.sdk.util.InstanceBuilder.build(InstanceBuilder.java:162) at org.apache.beam.sdk .runners.PipelineRunner.fromOptions(PipelineRunner.java:56) at org.apache.beam.sdk.Pipeline.create(Pipeline.java:135) at com.dynaobj ect.apachebeamexperiment.MinimalWordCount.main(MinimalWordCount.java:77)によって引き起こさ :sun.reflect.NativeMethodAccessorImpl.invokeでsun.reflect.NativeMethodAccessorImpl.invoke0のにjava.lang.reflect.InvocationTargetException (ネイティブメソッド) (不明なソース) at sun.reflect.DelegatingMethodAccessorImpl.invoke(不明なソース) at java.lang.reflect.Method.invoke(不明なソース) at org.apache.beam.sdk.util.InstanceBuilder.buildFromMethod(InstanceBuilder.java:222) ) ... 4 more 原因:java.lang.IllegalArgumentException:DataflowRunnerはgcpTempLocationが必要ですが、 から値を取得できませんでした。PipelineOptions at org.apache.beam.runners.dataflow.DataflowRunner.fromオプション(DataflowRunner.java:212) ... 9 more 原因:java.lang.IllegalArgumentException:gcpTempLocationのデフォルト値を構築中にエラーが発生しました:tempLocationが有効なGCSパス、gs:// tempxyzではない ではありません。 org.apache.beam.sdk.options.GcpOptions $ GcpTempLocationFactory.createでorg.apache.beam.sdk.options.GcpOptions $ GcpTempLocationFactory.create(GcpOptions.java:219) (GcpOptions.java:205)で (ProxyInvocationHandler.java:575) (org.apache.beam.sdk.options.ProxyInvocationHandler.java:516) .sdk.options.ProxyInvocationHandler.invoke(ProxyInvocationHandler.java:155) com.sun.proxy。$ Proxy15.getGcpTempLocation(不明なソース) at org.apache.beam.runners.dataflow.DataflowRunner.fromOptions(DataflowRunner.java :210) ... 9 more 発生原因:java.lang.IllegalArgumentException:出力パスが存在しないか、または書き込み可能でない:gs:// tempxyz at org.apache.beam.sdk.repackaged.com.google.common.base.Preconditions.checkArgument org.apache.beam.sdk.util.GcsPathValidator.validateOutputFilePrefixSupportedでorg.apache.beam.sdk.util.GcsPathValidator.verifyPathIsAccessible(GcsPathValidator.java:78) でPreconditions.java:191) (GcsPathValidator.java:62) at org.apache.beam.sdk.options.GcpOptions $ GcpTempLocationFactory.create(GcpOptions.java:217) ...15 more