From a10b64eed4c25790a20cc2f80226d23e2ab2067b Mon Sep 17 00:00:00 2001 From: bchambers Date: Tue, 8 Mar 2016 10:36:27 -0800 Subject: [PATCH] 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 5fbbcac4114c0..cd0ebc6d70af1 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 uniquifier) { + return String.format("To debug your job, visit Google Cloud Debugger at: " + + "https://console.developers.google.com/debug?project=%s&dbgee=%s", + projectId, uniquifier); + } + 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) {