[zeppelin] branch master updated: [minor] Add json to error message in JobManager

[zj...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

zjffdu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/zeppelin.git


The following commit(s) were added to refs/heads/master by this push:
     new d4b8c95  [minor] Add json to error message in JobManager
d4b8c95 is described below

commit d4b8c95a1db0b7f2a61fe24a0630d603ab05595a
Author: Jeff Zhang <zj...@apache.org>
AuthorDate: Tue Apr 7 17:45:52 2020 +0800

    [minor] Add json to error message in JobManager
---
 flink/src/main/java/org/apache/zeppelin/flink/JobManager.java | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/flink/src/main/java/org/apache/zeppelin/flink/JobManager.java b/flink/src/main/java/org/apache/zeppelin/flink/JobManager.java
index 0aab84f..527b0f7 100644
--- a/flink/src/main/java/org/apache/zeppelin/flink/JobManager.java
+++ b/flink/src/main/java/org/apache/zeppelin/flink/JobManager.java
@@ -159,8 +159,9 @@ public class JobManager {
     @Override
     public void run() {
       while (!Thread.currentThread().isInterrupted() && running.get()) {
+        JsonNode rootNode = null;
         try {
-          JsonNode rootNode = Unirest.get(flinkWebUI + "/jobs/" + jobId.toString())
+          rootNode = Unirest.get(flinkWebUI + "/jobs/" + jobId.toString())
                   .asJson().getBody();
           JSONArray vertices = rootNode.getObject().getJSONArray("vertices");
           int totalTasks = 0;
@@ -195,7 +196,7 @@ public class JobManager {
             context.out.flush();
           }
         } catch (Exception e) {
-          LOGGER.error("Fail to poll flink job progress via rest api", e);
+          LOGGER.error("Fail to poll flink job progress via rest api, rest api: " + rootNode, e);
         }
       }
     }