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
}
然而,在工作池的GCE情况下保持在美国地区旋转起来(us-central1-f
):
为什么工人不在特定区域内旋转?