From f729bdae89ec899cc0e91120f521d20992caf240 Mon Sep 17 00:00:00 2001 From: bchambers Date: Tue, 8 Mar 2016 10:36:27 -0800 Subject: [PATCH 1/2] Print link to debugger UI After successfully registering a debuggee, print a link to go to the appropriate UI. --- .../dataflow/sdk/runners/DataflowPipelineRunner.java | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowPipelineRunner.java b/sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowPipelineRunner.java index c90b904235876..958b70cc41801 100644 --- a/sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowPipelineRunner.java +++ b/sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowPipelineRunner.java @@ -424,6 +424,12 @@ private PCollection applyWindow( return super.apply(new AssignWindows<>(transform), input); } + private String debuggerMessage(String projectId, String uniqifier) { + return String.format("To view the debugger console, go to " + + "https://console.developers.google.com/debug?project=%s&dbgee=%s", + projectId, uniqifier); + } + private void maybeRegisterDebuggee(DataflowPipelineOptions options, String uniquifier) { if (!options.getEnableCloudDebugger()) { return; @@ -436,6 +442,8 @@ private void maybeRegisterDebuggee(DataflowPipelineOptions options, String uniqu Clouddebugger debuggerClient = Transport.newClouddebuggerClient(options).build(); Debuggee debuggee = registerDebuggee(debuggerClient, uniquifier); options.setDebuggee(debuggee); + + System.out.println(debuggerMessage(options.getProject(), debuggee.getUniquifier())); } private Debuggee registerDebuggee(Clouddebugger debuggerClient, String uniquifier) { From 7fd1fc22a3836557e649884ff15caa145d21103f Mon Sep 17 00:00:00 2001 From: bchambers Date: Wed, 23 Mar 2016 11:51:06 -0700 Subject: [PATCH 2/2] Update. --- .../cloud/dataflow/sdk/runners/DataflowPipelineRunner.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowPipelineRunner.java b/sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowPipelineRunner.java index 958b70cc41801..d6c5a9ecf5533 100644 --- a/sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowPipelineRunner.java +++ b/sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowPipelineRunner.java @@ -424,10 +424,10 @@ private PCollection applyWindow( return super.apply(new AssignWindows<>(transform), input); } - private String debuggerMessage(String projectId, String uniqifier) { - return String.format("To view the debugger console, go to " + private String debuggerMessage(String projectId, String uniquifier) { + return String.format("To debug your job, visit Google Cloud Debugger at: " + "https://console.developers.google.com/debug?project=%s&dbgee=%s", - projectId, uniqifier); + projectId, uniquifier); } private void maybeRegisterDebuggee(DataflowPipelineOptions options, String uniquifier) {