Merge pull request byzer-org#507 from allwefantasy/mlsql

修正as 表名bug
ylpu · Sep 6, 2018 · 6a54ff3 · 6a54ff3
2 parents 40c2610 + d23e7b0
commit 6a54ff3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/streamingpro-mlsql/src/main/java/streaming/dsl/SelectAdaptor.scala b/streamingpro-mlsql/src/main/java/streaming/dsl/SelectAdaptor.scala
@@ -22,7 +22,7 @@ class SelectAdaptor(scriptSQLExecListener: ScriptSQLExecListener) extends DslAda
 
     val chunks = wowText.split("\\s+")
     val tableName = chunks.last.replace(";", "")
-    val sql = originalText.replaceAll(s"as[\\s|\\n]+${tableName}", "")
+    val sql = wowText.replaceAll(s"as[\\s|\\n]+${tableName}", "")
     scriptSQLExecListener.sparkSession.sql(sql).createOrReplaceTempView(tableName)
     scriptSQLExecListener.setLastSelectTable(tableName)
   }