From ac201e3a8bf7e88443b2297faba02bebab8e52a1 Mon Sep 17 00:00:00 2001 From: "jiachuan.zhu" Date: Fri, 29 Apr 2022 17:06:44 +0800 Subject: [PATCH] Fix pagination bug --- .../src/main/java/tech/mlsql/datasource/impl/MLSQLRest.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/streamingpro-mlsql/src/main/java/tech/mlsql/datasource/impl/MLSQLRest.scala b/streamingpro-mlsql/src/main/java/tech/mlsql/datasource/impl/MLSQLRest.scala index e0ee608d8..d150eee60 100644 --- a/streamingpro-mlsql/src/main/java/tech/mlsql/datasource/impl/MLSQLRest.scala +++ b/streamingpro-mlsql/src/main/java/tech/mlsql/datasource/impl/MLSQLRest.scala @@ -22,8 +22,8 @@ import tech.mlsql.dsl.adaptor.DslTool import tech.mlsql.tool.{HDFSOperatorV2, Templates2} import java.net.URLEncoder -import java.nio.charset.StandardCharsets.UTF_8 import java.nio.charset.Charset +import java.nio.charset.StandardCharsets.UTF_8 import java.util.UUID import scala.collection.mutable.ArrayBuffer @@ -96,7 +96,7 @@ class MLSQLRest(override val uid: String) extends MLSQLSource if (debug) { logInfo(format(s"Started to request Page ${url} ")) } - val df = _http(config.path, config.config, skipParams, config.df.get.sparkSession) + val df = _http(url, config.config, skipParams, config.df.get.sparkSession) val row = df.select(F.col("content").cast(StringType), F.col("status")).head val status = row.getInt(1) (status, df)