From 8d0788e8a9d1287381a3a697ef64542a5c52c080 Mon Sep 17 00:00:00 2001 From: Jeff Zhang Date: Fri, 18 Dec 2020 16:35:13 +0800 Subject: [PATCH] [Minor] Add more logging --- .../src/main/java/org/apache/zeppelin/jdbc/JDBCInterpreter.java | 1 + .../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 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; }