[zeppelin] branch branch-0.9 updated: [hotfix] FLINK_HOME is not injected into exception messsage

[zj...@apache.org]

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 9159372  [hotfix] FLINK_HOME is not injected into exception messsage
9159372 is described below

commit 9159372a60404f0ecf87d194b292bfe9428b773f
Author: Jeff Zhang <zj...@apache.org>
AuthorDate: Wed Apr 1 13:45:38 2020 +0800

    [hotfix] FLINK_HOME is not injected into exception messsage
---
 .../zeppelin/interpreter/launcher/FlinkInterpreterLauncher.java       | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/zeppelin-plugins/launcher/flink/src/main/java/org/apache/zeppelin/interpreter/launcher/FlinkInterpreterLauncher.java b/zeppelin-plugins/launcher/flink/src/main/java/org/apache/zeppelin/interpreter/launcher/FlinkInterpreterLauncher.java
index c714b04..fe3adf7 100644
--- a/zeppelin-plugins/launcher/flink/src/main/java/org/apache/zeppelin/interpreter/launcher/FlinkInterpreterLauncher.java
+++ b/zeppelin-plugins/launcher/flink/src/main/java/org/apache/zeppelin/interpreter/launcher/FlinkInterpreterLauncher.java
@@ -40,10 +40,10 @@ public class FlinkInterpreterLauncher extends StandardInterpreterLauncher {
     }
     File flinkHomeFile = new File(flinkHome);
     if (!flinkHomeFile.exists()) {
-      throw new IOException(String.format("FLINK_HOME {} doesn't exist", flinkHome));
+      throw new IOException(String.format("FLINK_HOME %s doesn't exist", flinkHome));
     }
     if (flinkHomeFile.isFile()) {
-      throw new IOException(String.format("FLINK_HOME {} is a file, but should be directory",
+      throw new IOException(String.format("FLINK_HOME %s is a file, but should be directory",
               flinkHome));
     }
     envs.put("FLINK_CONF_DIR", flinkHome + "/conf");