fix test

Author: ruanhang1993

Dockerfile

@@ -17,7 +17,7 @@
 
 FROM flink
 
-ARG FLINK_CDC_VERSION=3.3-SNAPSHOT
+ARG FLINK_CDC_VERSION=3.4-SNAPSHOT
 ARG PIPELINE_DEFINITION_FILE
 
 RUN mkdir -p /opt/flink-cdc

tools/mig-test/datastream/compile_jobs.rb

@@ -16,7 +16,7 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
-JOB_VERSIONS = %w[3.2.0 3.2.1 3.3-SNAPSHOT]
+JOB_VERSIONS = %w[3.2.0 3.2.1 3.3.0 3.4-SNAPSHOT]
 
 JOB_VERSIONS.each do |version|
   puts "Compiling DataStream job for CDC #{version}"

tools/mig-test/datastream/datastream-3.3-SNAPSHOT/pom.xml

@@ -22,13 +22,13 @@ limitations under the License.
 
     <groupId>org.apache.flink</groupId>
     <artifactId>datastream-job</artifactId>
-    <version>3.3-SNAPSHOT</version>
+    <version>3.4-SNAPSHOT</version>
     <packaging>jar</packaging>
 
     <properties>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
         <flink.version>1.19.1</flink.version>
-        <flink.cdc.version>3.3-SNAPSHOT</flink.cdc.version>
+        <flink.cdc.version>3.4-SNAPSHOT</flink.cdc.version>
         <debezium.version>1.9.7.Final</debezium.version>
         <scala.binary.version>2.12</scala.binary.version>
         <slf4j.version>2.0.13</slf4j.version>

tools/mig-test/datastream/run_migration_test.rb

@@ -93,7 +93,7 @@ def test_migration(from_version, to_version)
   end
 end
 
-version_list = %w[3.2.0 3.2.1 3.3-SNAPSHOT]
+version_list = %w[3.2.0 3.2.1 3.3.0 3.4-SNAPSHOT]
 version_result = Hash.new('❓')
 @failures = []
 

tools/mig-test/prepare_libs.rb

@@ -38,9 +38,10 @@ def gen_version(tag)
 RELEASED_VERSIONS = {
   '3.2.0': gen_version('3.2.0'),
   '3.2.1': gen_version('3.2.1'),
+  '3.3.0': gen_version('3.3.0'),
 }.freeze
 
-HEAD_VERSION = '3.3-SNAPSHOT'
+HEAD_VERSION = '3.4-SNAPSHOT'
 
 def download_or_get(link)
   `mkdir -p cache`

tools/mig-test/run_migration_test.rb

@@ -118,8 +118,8 @@ def test_migration(from_version, to_version)
 end
 
 version_list = case ARGV[0]
-               when '1.19.1' then %w[3.2.0 3.2.1 3.3-SNAPSHOT]
-               when '1.20.0' then %w[3.2.1 3.3-SNAPSHOT]
+               when '1.19.1' then %w[3.2.0 3.2.1 3.3.0 3.4-SNAPSHOT]
+               when '1.20.0' then %w[3.2.1 3.3.0 3.4-SNAPSHOT]
                else []
                end