upgrade pyjava to 0.2.6

xiejiajun · Jan 9, 2020 · c3aaee1 · c3aaee1
1 parent 5b0bc4b
commit c3aaee1
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 10 deletions.
diff --git a/pom.xml b/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>

diff --git a/streamingpro-mlsql/src/main/java/tech/mlsql/ets/PluginCommand.scala b/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) = {