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

fix ds pulgin uninstall

Author: allwefantasy

pom.xml

@@ -70,7 +70,7 @@
         <mlsql-ps-service-version>1.3.5</mlsql-ps-service-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>
+        <mysql-binlog-version>1.0.0</mysql-binlog-version>
         <mlsql-scheduler-version>0.1.0</mlsql-scheduler-version>
     </properties>
 

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

@@ -277,16 +277,12 @@ 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 =>
-//    }
+  def removeDS(pluginName: String, fullFormat: String, shortFormat: Option[String], callback: () => Unit) = {
+    val dataSource = Class.forName(fullFormat).newInstance()
+    if (dataSource.isInstanceOf[MLSQLRegistry]) {
+      dataSource.asInstanceOf[MLSQLRegistry].unRegister()
+    }
+    callback()
   }
 
   def registerDS(pluginName: String, className: String, commandName: Option[String], callback: () => Unit) = {