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 837de10c81d..d63358b7ea1 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 @@ private InterpreterResult executeSql(String dbPrefix, String sql, try { List 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 526e22aef77..489ed0d2336 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 @@ && getDeployMode().equals("cluster")) { LOGGER.warn("spark-defaults.conf doesn't exist: {}", sparkDefaultFile.getAbsolutePath()); } - LOGGER.debug("buildEnvFromProperties: {}", env); + LOGGER.info("buildEnvFromProperties: {}", env); return env; }