Update externals/kyuubi-flink-sql-engine/src/test/scala/org/apache/ky…

…uubi/engine/flink/operation/FlinkEngineInitializeSuite.scala
apache · Nov 2, 2023 · b1720ec · b1720ec
1 parent 0782738
commit b1720ec
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/.../src/test/scala/org/apache/kyuubi/engine/flink/operation/FlinkEngineInitializeSuite.scala b/.../src/test/scala/org/apache/kyuubi/engine/flink/operation/FlinkEngineInitializeSuite.scala
@@ -36,12 +36,12 @@ class FlinkEngineInitializeSuite extends HiveJDBCTestHelper
 
   protected val ENGINE_SESSION_INITIALIZE_SQL_VALUE: String =
     """create catalog cat_b with ('type'='generic_in_memory');
-      create table blackhole(i int) with ('connector'='blackhole');
-      create table datagen(i int) with (
-      'connector'='datagen',
-      'fields.i.kind'='sequence',
-      'fields.i.start'='1',
-      'fields.i.end'='10')""".stripMargin
+      |create table blackhole(i int) with ('connector'='blackhole');
+      |create table datagen(i int) with (
+      |'connector'='datagen',
+      |'fields.i.kind'='sequence',
+      |'fields.i.start'='1',
+      |'fields.i.end'='10')""".stripMargin
 
   override def withKyuubiConf: Map[String, String] = {
     Map(