0

我想我的數據流(Java SDK的2.0.0)管道的區域設置爲australia-southeast1-a一個,australia-southeast1-b,或australia-southeast1-c(即在悉尼的地區之一):爲什麼Dataflow工作人員不尊重新的悉尼地區?

public static void main(String... args) { 
     DataflowPipelineOptions options = PipelineOptionsFactory 
       .fromArgs(args) 
       .withValidation() 
       .as(DataflowPipelineOptions.class); 
     options.setRunner(DataflowRunner.class); 
     options.setJobName("sydney-dataflow-pipeline"); 
     options.setStagingLocation("gs://<redacted>/jars"); 
     options.setTempLocation("gs://<redacted>/jars"); 
     options.setRegion("australia-southeast1-a"); //<<--trying to set region to Sydney 
     options.setMaxNumWorkers(3); 
     Pipeline pipeline = Pipeline.create(options); 
     pipeline.apply 
     [..] 
     pipeline.run(); //run it 
    } 

enter image description here

然而,在工作池的GCE情況下保持在美國地區旋轉起來(us-central1-f):

enter image description here

爲什麼工人不在特定區域內旋轉?

回答

2

Javadoc列出了此方法@Hidden@Experimental,同注:

「雲數據流的服務還沒有兌現此設置但是,添加 一次服務支持那麼這個SDK的用戶會能夠 控制該地區。「

setZone方法仍可用於控制工作人員的位置。

相關問題