update

byzer-org · Oct 12, 2022 · 06fb1a2 · 06fb1a2
1 parent 1137cb6
commit 06fb1a2
Show file tree

Hide file tree

Showing 5 changed files with 10 additions and 6 deletions.
diff --git a/...sql-autosuggest/src/test/java/com/intigua/antlr4/autosuggest/AutoSuggestContextTest.scala b/...sql-autosuggest/src/test/java/com/intigua/antlr4/autosuggest/AutoSuggestContextTest.scala
@@ -86,7 +86,7 @@ class AutoSuggestContextTest extends BaseTest with BeforeAndAfterEach with Loggi
         |SELECT CAST(25.65 AS int) from jack;
         |""".stripMargin).tokens.asScala.toList
 
-    wow.foreach(item => log.info("{} {}", item.getText, item.getType))
+    wow.foreach(item => log.info(s"${item.getText} ${item.getType}"))
   }
 
   test("load/select 4/10 select ke[cursor] from") {

diff --git a/streamingpro-commons/src/main/java/streaming/common/zk/Path.java b/streamingpro-commons/src/main/java/streaming/common/zk/Path.java
@@ -121,11 +121,14 @@ public static void main(String[] args) {
 
 
         Path p = new Path("/video/_index/pid");
+        System.out.println(p.getPathString());
+        System.out.println(p.getParentPath().getPathString());
+        System.out.println(p.getPathString());
         if (logger.isInfoEnabled()) {
             logger.info(
-                        "Path: {} \n ParentPath: {} \n ",
-                        p.getPathString(),
-                        p.getParentPath().getPathString()
+                    "Path: {} \n ParentPath: {} \n ",
+                    p.getPathString(),
+                    p.getParentPath().getPathString()
             );
         }
 

diff --git a/streamingpro-commons/src/main/java/streaming/common/zk/ZKClient.java b/streamingpro-commons/src/main/java/streaming/common/zk/ZKClient.java
@@ -169,6 +169,7 @@ public void main(String[] args) throws InterruptedException {
 
             @Override
             public void setConf(String conf) {
+                System.out.println(conf);
                 if (logger.isInfoEnabled()) {
                     logger.info(String.format("conf: %s", conf));
                 }

diff --git a/streamingpro-commons/src/main/java/streaming/common/zk/ZKConfUtil.java b/streamingpro-commons/src/main/java/streaming/common/zk/ZKConfUtil.java
@@ -122,6 +122,7 @@ public void checkAndAddPath(Path path) {
             } else {
 
                 checkAndAddPath(path.getParentPath());
+                System.out.println("add path " + p);
                 if (logger.isInfoEnabled()) {
                     logger.info("Add path {}", p);
                 }

diff --git a/...re/src/main/java/tech/mlsql/runtime/plugins/exception_render/DefaultExceptionRender.scala b/...re/src/main/java/tech/mlsql/runtime/plugins/exception_render/DefaultExceptionRender.scala
@@ -2,12 +2,11 @@ package tech.mlsql.runtime.plugins.exception_render
 
 import streaming.log.WowLog
 import tech.mlsql.app.ExceptionRender
-import tech.mlsql.common.utils.log.Logging
 
 import scala.collection.mutable.ArrayBuffer
 
 
-class DefaultExceptionRender extends ExceptionRender with WowLog with Logging {
+class DefaultExceptionRender extends ExceptionRender with WowLog {
   override def format(e: Exception): String = {
     val msgBuffer = ArrayBuffer[String]()
     format_full_exception(msgBuffer, e)