Ich versuche, das MinimalWordCount-Beispiel mit dem DataFlowRunner von Eclipse auf Windows mit MinimalWordCount -> Ausführen als Java-Anwendung von mit in Eclipse, der gleiche Lagercode aus dem Beispiel zu verwenden mein gcs-bucket, allerdings bekomme ich durchweg die folgende ausnahme, kann jemand mich wissen lassen, was das problem hier ist?Apache Beam MinimalWordcount Beispiel mit Dataflow Runner auf Eklipse
- Ich habe überprüft, dass der Bucket-Name korrekt ist.
- Ich habe bereits die gcloud init auf meinem Windows-Rechner ausgeführt.
Exception in thread "main" java.lang.RuntimeException: Fehler beim konstruieren weise aus Fabrikmethode DataflowRunner # fromOptions (Schnittstelle org.apache.beam.sdk.options.PipelineOptions) bei org .apache.beam.sdk.util.InstanceBuilder.buildFromMethod (InstanceBuilder.java:233) bei org.apache.beam.sdk.util.InstanceBuilder.build (InstanceBuilder.java:162) bei org.apache.beam.sdk .runners.PipelineRunner.fromOptions (PipelineRunner.java:56) bei org.apache.beam.sdk.Pipeline.create (Pipeline.java:135) bei com.dynaobj ect.apachebeamexperiment.MinimalWordCount.main (MinimalWordCount.java:77) Verursacht durch: java.lang.reflect.InvocationTargetException bei sun.reflect.NativeMethodAccessorImpl.invoke0 (Mutter Methode) bei sun.reflect.NativeMethodAccessorImpl.invoke (Unknown Source) bei sun.reflect.DelegatingMethodAccessorImpl.invoke (Unbekannte Quelle) bei java.lang.reflect.Method.invoke (Unbekannte Quelle) bei org.apache.beam.sdk.util.InstanceBuilder.buildFromMethod (InstanceBuilder.java:222) ... 4 weitere verursacht durch: java.lang.IllegalArgumentException: DataflowRunner erfordert gcpTempLocation, scheiterte aber mit einem Wert von PipelineOptions bei org.apache.beam.runners.dataflow.DataflowRunner.from abrufen Optionen (DataflowRunner.java:212) ... 9 mehr verursacht durch: java.lang.IllegalArgumentException: Fehler beim Erstellen des Standardwerts für gcpTempLocation: tempLocation ist kein gültiger GCS-Pfad, gs: // tempxyz. bei org.apache.beam.sdk.options.GcpOptions $ GcpTempLocationFactory.create (GcpOptions.java:219) bei org.apache.beam.sdk.options.GcpOptions $ GcpTempLocationFactory.create (GcpOptions.java:205) at org.apache.beam.sdk.options.ProxyInvocationHandler.returnDefaultHelper (ProxyInvocationHandler.java:575) bei org.apache.beam.sdk.options.ProxyInvocationHandler.getDefault (ProxyInvocationHandler.java:516) bei org.apache.beam .sdk.options.ProxyInvocationHandler.invoke (ProxyInvocationHandler.java:155) bei com.sun.proxy. $ Proxy15.getGcpTempLocation (Unknown Source) bei org.apache.beam.runners.dataflow.DataflowRunner.fromOptions (DataflowRunner.java : 210) ... 9 mehr Erstellt von: java.lang.IllegalArgumentException: Der Ausgabepfad existiert nicht oder kann nicht geschrieben werden: gs: // tempxyz unter org.apache.beam.sdk.repackaged.com.google.common.base.Preconditions.checkArgument (Preconditions.java:191) bei org.apache.beam.sdk.util.GcsPathValidator.verifyPathIsAccessible (GcsPathValidator.java:78) bei org.apache.beam.sdk.util.GcsPathValidator.validateOutputFilePrefixSupported (GcsPathValidator.java:62) bei org.apache.beam.sdk.options.GcpOptions $ GcpTempLocationFactory.create (GcpOptions.java:217) ...15 mehr