Update flink-scala-api to 1.18.1_1.1.7

flink-extended · Oct 20, 2024 · 3d9efc6 · 3d9efc6
1 parent 1017ae2
commit 3d9efc6
Show file tree

Hide file tree

Showing 6 changed files with 24 additions and 21 deletions.
diff --git a/modules/examples/scripts/PubSubConnectorWithJson.sc b/modules/examples/scripts/PubSubConnectorWithJson.sc
@@ -1,5 +1,5 @@
 //> using toolkit default
-//> using dep "org.flinkextended::flink-scala-api:1.18.1_1.1.6"
+//> using dep "org.flinkextended::flink-scala-api:1.18.1_1.1.7"
 //> using dep "org.apache.flink:flink-clients:1.18.1"
 //> using dep org.apache.flink:flink-connector-gcp-pubsub:3.1.0-1.18
 

diff --git a/modules/examples/scripts/debug-sql.sc b/modules/examples/scripts/debug-sql.sc
@@ -1,4 +1,4 @@
-import $ivy.`org.flinkextended::flink-scala-api:1.18.1_1.1.6`
+import $ivy.`org.flinkextended::flink-scala-api:1.18.1_1.1.7`
 
 import $ivy.`org.apache.flink:flink-clients:1.18.1`
 
@@ -18,7 +18,7 @@ import org.apache.flinkx.api.serializers._
 
 import java.lang.{Long => JLong}
 
-val env = StreamExecutionEnvironment.getExecutionEnvironment
+val env  = StreamExecutionEnvironment.getExecutionEnvironment
 val tEnv = StreamTableEnvironment.create(env.getJavaEnv)
 
 val settings = EnvironmentSettings.newInstance().inStreamingMode().build()
@@ -39,17 +39,20 @@ table.createTemporaryTable(
 )
 
 val tableDescriptor = TableDescriptor
-      .forConnector("datagen")
-      .schema(
-        Schema.newBuilder
-          .column("id", DataTypes.INT.notNull)
-          .column("a", DataTypes.ROW(DataTypes.FIELD("np", DataTypes.INT.notNull())).notNull())
-          .build)
+  .forConnector("datagen")
+  .schema(
+    Schema.newBuilder
+      .column("id", DataTypes.INT.notNull)
+      .column("a", DataTypes.ROW(DataTypes.FIELD("np", DataTypes.INT.notNull())).notNull())
       .build
+  )
+  .build
 table.createTemporaryTable("t1", tableDescriptor)
 table.createTemporaryTable("t2", tableDescriptor)
 // table.dropTemporaryTable("t1")
 // table.dropTemporaryTable("t2")
 
-val res = table.executeSql("EXPLAIN SELECT a.id, COALESCE(a.a.np, b.a.np) c1, IFNULL(a.a.np, b.a.np) c2 FROM t1 a left JOIN t2 b ON a.id=b.id where a.a is null or a.a.np is null")
+val res = table.executeSql(
+  "EXPLAIN SELECT a.id, COALESCE(a.a.np, b.a.np) c1, IFNULL(a.a.np, b.a.np) c2 FROM t1 a left JOIN t2 b ON a.id=b.id where a.a is null or a.a.np is null"
+)
 res.print
diff --git a/modules/examples/scripts/flink-scala-cli.scala b/modules/examples/scripts/flink-scala-cli.scala
@@ -1,4 +1,4 @@
-//> using dep "org.flinkextended::flink-scala-api:1.18.1_1.1.6"
+//> using dep "org.flinkextended::flink-scala-api:1.18.1_1.1.7"
 //> using dep "org.apache.flink:flink-clients:1.18.1"
 
 import org.apache.flinkx.api.*
@@ -12,7 +12,7 @@ import java.io.File
     .getOrElse(Array.empty[File])
   val elems = files.filter(_.isFile).map(_.getAbsolutePath())
 
-  val env = StreamExecutionEnvironment.getExecutionEnvironment
+  val env  = StreamExecutionEnvironment.getExecutionEnvironment
   val text = env.fromElements(elems*)
 
   text.addSink(logger.info(_))

diff --git a/modules/examples/scripts/gen-csv-file.sc b/modules/examples/scripts/gen-csv-file.sc
@@ -1,4 +1,4 @@
-//> using dep "org.flinkextended::flink-scala-api:1.18.1_1.1.6"
+//> using dep "org.flinkextended::flink-scala-api:1.18.1_1.1.7"
 //> using dep "org.apache.flink:flink-clients:1.18.1"
 //> using dep "org.apache.flink:flink-csv:1.18.1"
 //> using dep "org.apache.flink:flink-connector-files:1.18.1"
@@ -12,9 +12,9 @@ import org.apache.flinkx.api.serializers._
 
 import java.lang.{Long => JLong}
 
-val env = StreamExecutionEnvironment.getExecutionEnvironment
+val env      = StreamExecutionEnvironment.getExecutionEnvironment
 val settings = EnvironmentSettings.newInstance.inStreamingMode.build
-val table = TableEnvironment.create(settings)
+val table    = TableEnvironment.create(settings)
 val schema = Schema.newBuilder
   .column("id", DataTypes.INT())
   .column("bid_price", DataTypes.DOUBLE())

diff --git a/modules/examples/scripts/gen-kafka-data.sc b/modules/examples/scripts/gen-kafka-data.sc
@@ -1,4 +1,4 @@
-//> using dep "org.flinkextended::flink-scala-api:1.18.1_1.1.6"
+//> using dep "org.flinkextended::flink-scala-api:1.18.1_1.1.7"
 //> using dep "org.apache.flink:flink-clients:1.18.1"
 //> using dep "org.apache.flink:flink-csv:1.18.1"
 //> using dep "org.apache.flink:flink-connector-files:1.18.1"
@@ -13,9 +13,9 @@ import org.apache.flinkx.api.serializers._
 
 import java.lang.{Long => JLong}
 
-val env = StreamExecutionEnvironment.getExecutionEnvironment
+val env      = StreamExecutionEnvironment.getExecutionEnvironment
 val settings = EnvironmentSettings.newInstance.inStreamingMode.build
-val table = TableEnvironment.create(settings)
+val table    = TableEnvironment.create(settings)
 val schema = Schema.newBuilder
   .column("id", DataTypes.INT())
   .column("bid_price", DataTypes.DOUBLE())
@@ -30,7 +30,7 @@ table.createTemporaryTable(
     .option(DataGenConnectorOptions.NUMBER_OF_ROWS, JLong(1000))
     .option("fields.id.kind", "sequence")
     .option("fields.id.start", "10001")
-    .option("fields.id.end",   "20000")
+    .option("fields.id.end", "20000")
     .build
 )
 

diff --git a/modules/examples/scripts/hybrid-source.sc b/modules/examples/scripts/hybrid-source.sc
@@ -1,4 +1,4 @@
-//> using dep "org.flinkextended::flink-scala-api:1.18.1_1.1.6"
+//> using dep "org.flinkextended::flink-scala-api:1.18.1_1.1.7"
 //> using dep "org.apache.flink:flink-clients:1.18.1"
 //> using dep "org.apache.flink:flink-csv:1.18.1"
 //> using dep "org.apache.flink:flink-connector-files:1.18.1"
@@ -26,7 +26,7 @@ val fileSource = FileSource
   .build
 
 val switchTimestamp = -1L
-val brokers = "confluentkafka-cp-kafka:9092"
+val brokers         = "confluentkafka-cp-kafka:9092"
 
 val kafkaSource = KafkaSource
   .builder[String]()