[zeppelin] branch branch-0.9 updated: [ZEPPELIN-4776]. The same flink job url is duplicated in fronted for streaming job

[zjffdu]

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

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


The following commit(s) were added to refs/heads/branch-0.9 by this push:
     new 4ede31a  [ZEPPELIN-4776]. The same flink job url is duplicated in 
fronted for streaming job
4ede31a is described below

commit 4ede31a9078a1b85e17d5d13dba05ba216958cba
Author: Jeff Zhang <zjf...@apache.org>
AuthorDate: Sat Apr 25 14:52:47 2020 +0800

    [ZEPPELIN-4776]. The same flink job url is duplicated in fronted for 
streaming job
    
    ### What is this PR for?
    
    This PR is to remove duplicated flink job url. In ZEPPELIN-4759, I remove 
the refresh step in frontend, so it is not necessary to send job url again for 
each data refresh. So in this PR, I remove sendFlinkJobUrl in flink streaming 
job.
    
    ### What type of PR is it?
    [Bug Fix ]
    
    ### Todos
    * [ ] - Task
    
    ### What is the Jira issue?
    * https://issues.apache.org/jira/browse/ZEPPELIN-4776
    
    ### How should this be tested?
    * CI pass
    
    ### Screenshots (if appropriate)
    
    ### Questions:
    * Does the licenses files need update? No
    * Is there breaking changes for older versions? No
    * Does this needs documentation? No
    
    Author: Jeff Zhang <zjf...@apache.org>
    
    Closes #3749 from zjffdu/ZEPPELIN-4776 and squashes the following commits:
    
    ff872efb9 [Jeff Zhang] [ZEPPELIN-4776]. The same flink job url is 
duplicated in fronted for streaming job
    
    (cherry picked from commit 564f166f26f1a76d581527cbcdfd4fe36f0b4335)
    Signed-off-by: Jeff Zhang <zjf...@apache.org>
---
 .../src/main/java/org/apache/zeppelin/flink/sql/AppendStreamSqlJob.java  | 1 -
 .../main/java/org/apache/zeppelin/flink/sql/SingleRowStreamSqlJob.java   | 1 -
 .../src/main/java/org/apache/zeppelin/flink/sql/UpdateStreamSqlJob.java  | 1 -
 3 files changed, 3 deletions(-)

diff --git 
a/flink/src/main/java/org/apache/zeppelin/flink/sql/AppendStreamSqlJob.java 
b/flink/src/main/java/org/apache/zeppelin/flink/sql/AppendStreamSqlJob.java
index 83a95c8..ba5b4fe 100644
--- a/flink/src/main/java/org/apache/zeppelin/flink/sql/AppendStreamSqlJob.java
+++ b/flink/src/main/java/org/apache/zeppelin/flink/sql/AppendStreamSqlJob.java
@@ -124,7 +124,6 @@ public class AppendStreamSqlJob extends 
AbstractStreamSqlJob {
   protected void refresh(InterpreterContext context) {
     context.out().clear(false);
     try {
-      jobManager.sendFlinkJobUrl(context);
       String result = buildResult();
       context.out.write(result);
       context.out.flush();
diff --git 
a/flink/src/main/java/org/apache/zeppelin/flink/sql/SingleRowStreamSqlJob.java 
b/flink/src/main/java/org/apache/zeppelin/flink/sql/SingleRowStreamSqlJob.java
index 7ef274a..20bad29 100644
--- 
a/flink/src/main/java/org/apache/zeppelin/flink/sql/SingleRowStreamSqlJob.java
+++ 
b/flink/src/main/java/org/apache/zeppelin/flink/sql/SingleRowStreamSqlJob.java
@@ -83,7 +83,6 @@ public class SingleRowStreamSqlJob extends 
AbstractStreamSqlJob {
     context.out().clear(false);
     String output = buildResult();
     context.out.write(output);
-    jobManager.sendFlinkJobUrl(context);
     LOGGER.debug("Refresh Output: " + output);
     context.out.flush();
   }
diff --git 
a/flink/src/main/java/org/apache/zeppelin/flink/sql/UpdateStreamSqlJob.java 
b/flink/src/main/java/org/apache/zeppelin/flink/sql/UpdateStreamSqlJob.java
index a9cc3c0..0353d89 100644
--- a/flink/src/main/java/org/apache/zeppelin/flink/sql/UpdateStreamSqlJob.java
+++ b/flink/src/main/java/org/apache/zeppelin/flink/sql/UpdateStreamSqlJob.java
@@ -106,7 +106,6 @@ public class UpdateStreamSqlJob extends 
AbstractStreamSqlJob {
   protected void refresh(InterpreterContext context) {
     context.out().clear(false);
     try {
-      jobManager.sendFlinkJobUrl(context);
       String result = buildResult();
       context.out.write(result);
       context.out.flush();