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/09/24 06:56:57 UTC
[zeppelin] branch master updated: [hotfix] Unable to run flink
interpreter in yarn interpreter mode when HIVE_CONF_DIR is empty
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 de97805 [hotfix] Unable to run flink interpreter in yarn interpreter mode when HIVE_CONF_DIR is empty
de97805 is described below
commit de978051ecfbe086a81ce455070e7a260440df3f
Author: Jeff Zhang <zj...@apache.org>
AuthorDate: Thu Sep 24 14:56:20 2020 +0800
[hotfix] Unable to run flink interpreter in yarn interpreter mode when HIVE_CONF_DIR is empty
---
.../zeppelin/interpreter/launcher/YarnRemoteInterpreterProcess.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/zeppelin-plugins/launcher/yarn/src/main/java/org/apache/zeppelin/interpreter/launcher/YarnRemoteInterpreterProcess.java b/zeppelin-plugins/launcher/yarn/src/main/java/org/apache/zeppelin/interpreter/launcher/YarnRemoteInterpreterProcess.java
index 4dca26e..cf5df4e 100644
--- a/zeppelin-plugins/launcher/yarn/src/main/java/org/apache/zeppelin/interpreter/launcher/YarnRemoteInterpreterProcess.java
+++ b/zeppelin-plugins/launcher/yarn/src/main/java/org/apache/zeppelin/interpreter/launcher/YarnRemoteInterpreterProcess.java
@@ -260,7 +260,7 @@ public class YarnRemoteInterpreterProcess extends RemoteInterpreterProcess {
FileUtils.forceDelete(flinkZip);
String hiveConfDir = launchContext.getProperties().getProperty("HIVE_CONF_DIR");
- if (org.apache.commons.lang3.StringUtils.isBlank(hiveConfDir)) {
+ if (!org.apache.commons.lang3.StringUtils.isBlank(hiveConfDir)) {
srcPath = localFs.makeQualified(new Path(new File(hiveConfDir).toURI()));
destPath = copyFileToRemote(stagingDir, srcPath, (short) 1);
addResource(fs, destPath, localResources, LocalResourceType.ARCHIVE, "hive_conf");