You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@zeppelin.apache.org by zj...@apache.org on 2020/06/18 04:13:02 UTC
[zeppelin] branch branch-0.9 updated: [ZEPPELIN-4889] [Flink] Error
logs in catch exception
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 6bfb5e9 [ZEPPELIN-4889] [Flink] Error logs in catch exception
6bfb5e9 is described below
commit 6bfb5e9d0fe6ac7f71f0809327be8d6708491836
Author: dijie <di...@mogu.com>
AuthorDate: Wed Jun 17 15:29:14 2020 +0800
[ZEPPELIN-4889] [Flink] Error logs in catch exception
### What is this PR for?
Fix error logs in catch exception
### What type of PR is it?
[Bug Fix ]
### Todos
* [ ] - Task
### What is the Jira issue?
https://issues.apache.org/jira/browse/ZEPPELIN-4889
### How should this be tested?
### Screenshots (if appropriate)
### Questions:
No questions.
Author: dijie <di...@mogu.com>
Closes #3804 from lonelyGhostisdog/ZEPPELIN-4889 and squashes the following commits:
636b69809 [dijie] [ZEPPELIN-4889] [Flink] Error logs in catch exception
(cherry picked from commit 9294062f28a2a7ba8625710eac3ccb95dd585d07)
Signed-off-by: Jeff Zhang <zj...@apache.org>
---
.../src/main/java/org/apache/zeppelin/flink/FlinkVersion.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink/flink-shims/src/main/java/org/apache/zeppelin/flink/FlinkVersion.java b/flink/flink-shims/src/main/java/org/apache/zeppelin/flink/FlinkVersion.java
index c0566ad..d593746 100644
--- a/flink/flink-shims/src/main/java/org/apache/zeppelin/flink/FlinkVersion.java
+++ b/flink/flink-shims/src/main/java/org/apache/zeppelin/flink/FlinkVersion.java
@@ -47,7 +47,7 @@ public class FlinkVersion {
}
} catch (Exception e) {
- logger.error("Can not recognize Spark version " + versionString +
+ logger.error("Can not recognize Flink version " + versionString +
". Assume it's a future release", e);
}
}