bump: flink to 1.20, cdc to 3.2

yuxiqian · Oct 12, 2024 · e7afd6a · e7afd6a
1 parent 722ce2d
commit e7afd6a
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/build.sbt b/build.sbt
@@ -3,8 +3,8 @@ idePackagePrefix := Some("io.github.yuxiqian.phaker")
 version := "0.1.0-SNAPSHOT"
 scalaVersion := "2.12.19"
 
-val flinkVersion = "1.18.1"
-val flinkCdcVersion = "3.1.1"
+val flinkVersion = "1.20.0"
+val flinkCdcVersion = "3.2.0"
 
 libraryDependencies ++= Seq(
   "org.apache.flink" % "flink-runtime" % flinkVersion % "provided",
@@ -14,6 +14,7 @@ libraryDependencies ++= Seq(
   "org.scalatest" %% "scalatest" % "3.2.19" % Test,
   "org.apache.flink" % "flink-clients" % flinkVersion % Test,
   "org.apache.flink" % "flink-streaming-java" % flinkVersion % Test,
+  "org.apache.flink" %% "flink-table-planner" % flinkVersion % Test,
   "org.apache.flink" % "flink-cdc-composer" % flinkCdcVersion % Test,
   "org.apache.flink" % "flink-cdc-pipeline-connector-values" % flinkCdcVersion % Test
 )
diff --git a/src/test/scala/PhakerTest.scala b/src/test/scala/PhakerTest.scala
@@ -36,7 +36,7 @@ class PhakerTest extends AnyFunSuite {
   test("Phaker to Values test") {
     import source.PhakerDataSourceOptions
 
-    import org.apache.flink.cdc.composer.definition.{RouteDef, TransformDef}
+    import org.apache.flink.cdc.composer.definition.{RouteDef, TransformDef, UdfDef}
 
     val composer = FlinkPipelineComposer.ofMiniCluster
 
@@ -74,6 +74,7 @@ class PhakerTest extends AnyFunSuite {
       sinkDef,
       Collections.emptyList[RouteDef],
       Collections.emptyList[TransformDef],
+      Collections.emptyList[UdfDef],
       pipelineConfig
     )