You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by da...@apache.org on 2016/03/23 20:24:42 UTC
[1/2] incubator-beam git commit: Print link to debugger UI
Repository: incubator-beam
Updated Branches:
refs/heads/master 63490fd63 -> db160faba
Print link to debugger UI
After successfully registering a debuggee, print a link to go to the
appropriate UI.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a10b64ee
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a10b64ee
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/a10b64ee
Branch: refs/heads/master
Commit: a10b64eed4c25790a20cc2f80226d23e2ab2067b
Parents: 63490fd
Author: bchambers <bc...@google.com>
Authored: Tue Mar 8 10:36:27 2016 -0800
Committer: Davor Bonaci <da...@google.com>
Committed: Wed Mar 23 12:14:10 2016 -0700
----------------------------------------------------------------------
.../cloud/dataflow/sdk/runners/DataflowPipelineRunner.java | 8 ++++++++
1 file changed, 8 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/a10b64ee/sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowPipelineRunner.java
----------------------------------------------------------------------
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 5fbbcac..cd0ebc6 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 @@ public class DataflowPipelineRunner extends PipelineRunner<DataflowPipelineJob>
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 @@ public class DataflowPipelineRunner extends PipelineRunner<DataflowPipelineJob>
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) {
[2/2] incubator-beam git commit: This closes #32
Posted by da...@apache.org.
This closes #32
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/db160fab
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/db160fab
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/db160fab
Branch: refs/heads/master
Commit: db160faba543ffe6188977c049e30607179643ac
Parents: 63490fd a10b64e
Author: Davor Bonaci <da...@google.com>
Authored: Wed Mar 23 12:14:31 2016 -0700
Committer: Davor Bonaci <da...@google.com>
Committed: Wed Mar 23 12:14:31 2016 -0700
----------------------------------------------------------------------
.../cloud/dataflow/sdk/runners/DataflowPipelineRunner.java | 8 ++++++++
1 file changed, 8 insertions(+)
----------------------------------------------------------------------