[Minor] Add more logging

Elvis0607 · Dec 18, 2020 · 8d0788e · 8d0788e
1 parent e2579d2
commit 8d0788e
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 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
@@ -716,6 +716,7 @@ private InterpreterResult executeSql(String dbPrefix, String sql,
     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/...gine/src/main/java/org/apache/zeppelin/interpreter/launcher/SparkInterpreterLauncher.java b/...gine/src/main/java/org/apache/zeppelin/interpreter/launcher/SparkInterpreterLauncher.java
@@ -221,7 +221,7 @@ && getDeployMode().equals("cluster")) {
       LOGGER.warn("spark-defaults.conf doesn't exist: {}", sparkDefaultFile.getAbsolutePath());
     }
 
-    LOGGER.debug("buildEnvFromProperties: {}", env);
+    LOGGER.info("buildEnvFromProperties: {}", env);
     return env;
 
   }