[zeppelin] branch master updated: [Minor] Add more logging

[zjffdu]

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 8d0788e  [Minor] Add more logging
8d0788e is described below

commit 8d0788e8a9d1287381a3a697ef64542a5c52c080
Author: Jeff Zhang <zjf...@apache.org>
AuthorDate: Fri Dec 18 16:35:13 2020 +0800

    [Minor] Add more logging
---
 jdbc/src/main/java/org/apache/zeppelin/jdbc/JDBCInterpreter.java        | 1 +
 .../apache/zeppelin/interpreter/launcher/SparkInterpreterLauncher.java  | 2 +-
 2 files changed, 2 insertions(+), 1 deletion(-)

diff --git a/jdbc/src/main/java/org/apache/zeppelin/jdbc/JDBCInterpreter.java 
b/jdbc/src/main/java/org/apache/zeppelin/jdbc/JDBCInterpreter.java
index 837de10..d63358b 100644
--- a/jdbc/src/main/java/org/apache/zeppelin/jdbc/JDBCInterpreter.java
+++ b/jdbc/src/main/java/org/apache/zeppelin/jdbc/JDBCInterpreter.java
@@ -716,6 +716,7 @@ public class JDBCInterpreter extends KerberosInterpreter {
     try {
       List<String>  sqlArray = sqlSplitter.splitSql(sql);
       for (String sqlToExecute : sqlArray) {
+        LOGGER.info("Execute sql: " + sqlToExecute);
         statement = connection.createStatement();
 
         // fetch n+1 rows in order to indicate there's more rows available 
(for large selects)
diff --git 
a/zeppelin-zengine/src/main/java/org/apache/zeppelin/interpreter/launcher/SparkInterpreterLauncher.java
 
b/zeppelin-zengine/src/main/java/org/apache/zeppelin/interpreter/launcher/SparkInterpreterLauncher.java
index 526e22a..489ed0d 100644
--- 
a/zeppelin-zengine/src/main/java/org/apache/zeppelin/interpreter/launcher/SparkInterpreterLauncher.java
+++ 
b/zeppelin-zengine/src/main/java/org/apache/zeppelin/interpreter/launcher/SparkInterpreterLauncher.java
@@ -221,7 +221,7 @@ public class SparkInterpreterLauncher extends 
StandardInterpreterLauncher {
       LOGGER.warn("spark-defaults.conf doesn't exist: {}", 
sparkDefaultFile.getAbsolutePath());
     }
 
-    LOGGER.debug("buildEnvFromProperties: {}", env);
+    LOGGER.info("buildEnvFromProperties: {}", env);
     return env;
 
   }