From be3d073d5fe51c490d6653d3fd94b4f49be5ed14 Mon Sep 17 00:00:00 2001 From: tobe Date: Fri, 24 Nov 2023 15:00:08 +0800 Subject: [PATCH] Log openmldb sql when executing --- .../com/_4paradigm/openmldb/batch/api/OpenmldbSession.scala | 2 ++ 1 file changed, 2 insertions(+) diff --git a/java/openmldb-batch/src/main/scala/com/_4paradigm/openmldb/batch/api/OpenmldbSession.scala b/java/openmldb-batch/src/main/scala/com/_4paradigm/openmldb/batch/api/OpenmldbSession.scala index 9a3113b4c09..a68512255ca 100755 --- a/java/openmldb-batch/src/main/scala/com/_4paradigm/openmldb/batch/api/OpenmldbSession.scala +++ b/java/openmldb-batch/src/main/scala/com/_4paradigm/openmldb/batch/api/OpenmldbSession.scala @@ -174,6 +174,8 @@ class OpenmldbSession { * @return */ def openmldbSql(sqlText: String): OpenmldbDataframe = { + logger.info("Try to execute OpenMLDB SQL: " + openmldbSql) + if (config.enableSparksql) { return OpenmldbDataframe(this, sparksql(sqlText)) }