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方法仍可用于控制工作人员的位置。

相关问题