MinimalWordCount를 사용하는 Windows에서 Eclipse의 DataFlowRunner를 사용하여 MinimalWordCount 예제를 실행하려고합니다. - Eclipse에서 with Java 응용 프로그램과 함께 실행합니다. 사용하는 예제와 동일한 주식 코드입니다. 내 gcs 양동이,하지만 난 일관되게 다음과 같은 예외가 하나, 내게 무슨 문제가 여기에 알려주 수 있습니까?Apache Beam Eclipse에서 Dataflow Runner를 사용하는 MinimalWordcount 예제
- 버킷 이름이 올바른지 확인했습니다.
- 이미 Windows 컴퓨터에서 gcloud init를 실행했습니다. 스레드에서
예외는 "주요"java.lang.RuntimeException가 : 에 실패는 조직에서 팩토리 메소드에서 DataflowRunner 번호의 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 (알 수없는 소스) sun.reflect.DelegatingMethodAccessorImpl.invoke (알 소스)에 org.apache.beam.sdk.util.InstanceBuilder.buildFromMethod java.lang.reflect.Method.invoke (알 소스)에 (InstanceBuilder.java:222에서 ) ... 4 개 에 의해 발생 : java.lang.IllegalArgumentException가이 : DataflowRunner는 gcpTempLocation 필요하지만 org.apache.beam.runners.dataflow.DataflowRunner.from에서 PipelineOptions 에서 값을 검색하지 못했습니다 옵션 (DataflowRunner.java:212) ... 9 더 많은 발생 원인 : 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)에서 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) com.sun.proxy. $ Proxy15.getGcpTempLocation (알 수없는 소스) at org.apache.beam.runners.dataflow.DataflowRunner.fromOptions (DataflowRunner.java : 210) ... 9 더 발생 원인 : java.lang.IllegalArgumentException : 출력 경로가 존재하지 않거나 쓰기 가능하지 않습니다. gs : // tempxyz at org.apache.beam.sdk.repackaged.com.google.common.base.Preconditions.checkArgument Preconditions.java:191) at org.apache.beam.sdk.util.GcsPathValidator.verifyPathIsAccessible (GcsPathValidator.java:78) at org.apache.beam.sdk.util.GcsPathValidator.validateOutputFilePrefixSupported (GcsPathValidator.java:62) at org.apache.beam.sdk.options.GcpOptions $ GcpTempLocationFactory.create (GcpOptions.java:217) ...15 더