diff --git a/.github/workflows/flink_cdc.yml b/.github/workflows/flink_cdc.yml
index 1e46f156bc..65c0bb84b5 100644
--- a/.github/workflows/flink_cdc.yml
+++ b/.github/workflows/flink_cdc.yml
@@ -315,16 +315,16 @@ jobs:
       - name: Prepare CDC versions
         run: CDC_SOURCE_HOME=$PWD ruby tools/mig-test/prepare_libs.rb
       - name: Prepare Flink distro
-        run: wget https://dlcdn.apache.org/flink/flink-{{ matrix.flink-version }}/flink-{{ matrix.flink-version }}-bin-scala_2.12.tgz && tar -xzvf flink-{{ matrix.flink-version }}-bin-scala_2.12.tgz
+        run: wget https://dlcdn.apache.org/flink/flink-${{ matrix.flink-version }}/flink-${{ matrix.flink-version }}-bin-scala_2.12.tgz && tar -xzvf flink-${{ matrix.flink-version }}-bin-scala_2.12.tgz
         working-directory: ./tools/mig-test
       - name: Patch Flink configs
-        run: FLINK_HOME=./flink-{{ matrix.flink-version }}/ ruby misc/patch_flink_conf.rb
+        run: FLINK_HOME=./flink-${{ matrix.flink-version }}/ ruby misc/patch_flink_conf.rb
         working-directory: ./tools/mig-test
       - name: Start containers
         run: cd conf && docker compose up -d
         working-directory: ./tools/mig-test
       - name: Run migration tests
-        run: FLINK_HOME=./flink-{{ matrix.flink-version }}/ ruby run_migration_test.rb
+        run: FLINK_HOME=./flink-${{ matrix.flink-version }}/ ruby run_migration_test.rb ${{ matrix.flink-version }}
         working-directory: ./tools/mig-test
       - name: Stop containers
         if: always()
@@ -355,10 +355,10 @@ jobs:
       - name: Prepare CDC versions
         run: CDC_SOURCE_HOME=$PWD ruby tools/mig-test/prepare_libs.rb
       - name: Prepare Flink distro
-        run: wget https://dlcdn.apache.org/flink/flink-{{ matrix.flink-version }}/flink-{{ matrix.flink-version }}-bin-scala_2.12.tgz && tar -xzvf flink-{{ matrix.flink-version }}-bin-scala_2.12.tgz
+        run: wget https://dlcdn.apache.org/flink/flink-${{ matrix.flink-version }}/flink-${{ matrix.flink-version }}-bin-scala_2.12.tgz && tar -xzvf flink-${{ matrix.flink-version }}-bin-scala_2.12.tgz
         working-directory: ./tools/mig-test
       - name: Patch Flink configs
-        run: FLINK_HOME=./flink-{{ matrix.flink-version }}/ ruby misc/patch_flink_conf.rb
+        run: FLINK_HOME=./flink-${{ matrix.flink-version }}/ ruby misc/patch_flink_conf.rb
         working-directory: ./tools/mig-test
       - name: Compile Dummy DataStream Jobs
         run: cd datastream && ruby compile_jobs.rb
@@ -367,7 +367,7 @@ jobs:
         run: cd conf && docker compose up -d
         working-directory: ./tools/mig-test
       - name: Run migration tests
-        run: cd datastream && FLINK_HOME=../flink-{{ matrix.flink-version }}/ ruby run_migration_test.rb
+        run: cd datastream && FLINK_HOME=../flink-${{ matrix.flink-version }}/ ruby run_migration_test.rb
         working-directory: ./tools/mig-test
       - name: Stop containers
         if: always()
diff --git a/tools/mig-test/run_migration_test.rb b/tools/mig-test/run_migration_test.rb
index d7c2fff284..1a454efe8f 100644
--- a/tools/mig-test/run_migration_test.rb
+++ b/tools/mig-test/run_migration_test.rb
@@ -114,7 +114,13 @@ def test_migration(from_version, to_version)
   end
 end
 
-version_list = %w[3.0.0 3.0.1 3.1.0 3.1.1 3.3-SNAPSHOT]
+version_list = case ARGV[0]
+               when '1.18.1' then %w[3.0.0 3.0.1 3.1.1 3.3-SNAPSHOT]
+               when '1.19.1' then %w[3.1.1 3.3-SNAPSHOT]
+               when '1.20.0' then %w[3.3-SNAPSHOT]
+               else []
+               end
+
 no_savepoint_versions = %w[3.0.0 3.0.1]
 version_result = Hash.new('❓')
 @failures = []
@@ -157,6 +163,6 @@ def test_migration(from_version, to_version)
 end
 puts "✅ - Compatible, ❌ - Not compatible, ❓ - Target version doesn't support `--from-savepoint`"
 
-if @failures.filter { |old_version, new_version| new_version == version_list.last && old_version != '3.1.0' }.any?
+if @failures.any?
   abort 'Some migration to snapshot version tests failed.'
 end