Я пытаюсь установить регион моего конвейера потока данных (Java SDK 2.0.0) на один из australia-southeast1-a
, australia-southeast1-b
или australia-southeast1-c
(т.е. один из регионов в Сиднее):
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
):
Почему рабочие не раскручиваются в указанном регионе?