Почему работники Dataflow не чествуют новый Сиднейский регион?

Я пытаюсь установить регион моего конвейера потока данных (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):

введите здесь описание изображения

Почему рабочие не раскручиваются в указанном регионе?


person Graham Polley    schedule 21.06.2017    source источник


Ответы (1)


Javadoc перечисляет этот метод как @Hidden и @Experimental с примечанием:

«Служба Cloud Dataflow еще не поддерживает этот параметр. Однако после добавления поддержки службы пользователи этого SDK смогут управлять регионом».

Метод setZone все еще можно использовать для управления местоположением рабочего.

person Sam McVeety    schedule 21.06.2017