From a51443d60001fe11fc9e9e8e99e8560128479912 Mon Sep 17 00:00:00 2001 From: Dan Halperin Date: Tue, 18 Oct 2016 09:42:50 -0700 Subject: [PATCH] Dataflow: API is in beta now --- .../org/apache/beam/runners/dataflow/util/MonitoringUtil.java | 2 +- .../apache/beam/runners/dataflow/util/MonitoringUtilTest.java | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/MonitoringUtil.java b/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/MonitoringUtil.java index d0146230c66f..a6afccdccb44 100644 --- a/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/MonitoringUtil.java +++ b/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/MonitoringUtil.java @@ -46,7 +46,7 @@ */ public final class MonitoringUtil { - private static final String GCLOUD_DATAFLOW_PREFIX = "gcloud alpha dataflow"; + private static final String GCLOUD_DATAFLOW_PREFIX = "gcloud beta dataflow"; private static final String ENDPOINT_OVERRIDE_ENV_VAR = "CLOUDSDK_API_ENDPOINT_OVERRIDES_DATAFLOW"; diff --git a/runners/google-cloud-dataflow-java/src/test/java/org/apache/beam/runners/dataflow/util/MonitoringUtilTest.java b/runners/google-cloud-dataflow-java/src/test/java/org/apache/beam/runners/dataflow/util/MonitoringUtilTest.java index 98d8ab60e815..6c5a2beb6fa6 100644 --- a/runners/google-cloud-dataflow-java/src/test/java/org/apache/beam/runners/dataflow/util/MonitoringUtilTest.java +++ b/runners/google-cloud-dataflow-java/src/test/java/org/apache/beam/runners/dataflow/util/MonitoringUtilTest.java @@ -133,7 +133,7 @@ public void testDontOverrideEndpointWithDefaultApi() { options.setProject(PROJECT_ID); options.setGcpCredential(new TestCredential()); String cancelCommand = MonitoringUtil.getGcloudCancelCommand(options, JOB_ID); - assertEquals("gcloud alpha dataflow jobs --project=someProject cancel 1234", cancelCommand); + assertEquals("gcloud beta dataflow jobs --project=someProject cancel 1234", cancelCommand); } @Test @@ -147,7 +147,7 @@ public void testOverridesEndpointWithStagedDataflowEndpoint() { String cancelCommand = MonitoringUtil.getGcloudCancelCommand(options, JOB_ID); assertEquals( "CLOUDSDK_API_ENDPOINT_OVERRIDES_DATAFLOW=https://dataflow.googleapis.com/v0neverExisted/ " - + "gcloud alpha dataflow jobs --project=someProject cancel 1234", + + "gcloud beta dataflow jobs --project=someProject cancel 1234", cancelCommand); }