Merge pull request byzer-org#1281 from allwefantasy/TRY

upgrade pyjava to 0.2.6

Author: allwefantasy

pom.xml

@@ -68,7 +68,7 @@
 
         <common-utils-version>0.2.1</common-utils-version>
         <mlsql-ps-service-version>1.3.5</mlsql-ps-service-version>
-        <pyjava-version>0.2.5</pyjava-version>
+        <pyjava-version>0.2.6</pyjava-version>
         <delta-plus-version>0.2.0</delta-plus-version>
         <mysql-binlog-version>1.0.0-SNAPSHOT</mysql-binlog-version>
         <mlsql-scheduler-version>0.1.0</mlsql-scheduler-version>

streamingpro-mlsql/src/main/java/tech/mlsql/ets/PluginCommand.scala

@@ -278,15 +278,15 @@ object PluginCommand {
   }
 
   def removeDS(pluginName: String, className: String, commandName: Option[String], callback: () => Unit) = {
-    val dataSource = Class.forName(className).newInstance()
-    if (dataSource.isInstanceOf[MLSQLRegistry]) {
-      dataSource.asInstanceOf[MLSQLRegistry].unRegister()
-    }
-    commandName match {
-      case Some(alisName) =>
-        callback()
-      case None =>
-    }
+//    val dataSource = Class.forName(className).newInstance()
+//    if (dataSource.isInstanceOf[MLSQLRegistry]) {
+//      dataSource.asInstanceOf[MLSQLRegistry].unRegister()
+//    }
+//    commandName match {
+//      case Some(alisName) =>
+//        callback()
+//      case None =>
+//    }
   }
 
   def registerDS(pluginName: String, className: String, commandName: Option[String], callback: () => Unit) = {