diff --git a/ci/scripts/deterministic-e2e-test.sh b/ci/scripts/deterministic-e2e-test.sh
index f93ded7bad4a3..e7c7b21310939 100755
--- a/ci/scripts/deterministic-e2e-test.sh
+++ b/ci/scripts/deterministic-e2e-test.sh
@@ -39,7 +39,7 @@ echo "--- deterministic simulation e2e, ci-3cn-2fe, batch"
 seq "$TEST_NUM" | parallel './risingwave_simulation ./e2e_test/batch/\*\*/\*.slt 2> $LOGDIR/batch-{}.log && rm $LOGDIR/batch-{}.log'
 
 echo "--- deterministic simulation e2e, ci-3cn-2fe, kafka source"
-seq "$TEST_NUM" | parallel './risingwave_simulation --kafka-datadir=./scripts/source/test_data ./e2e_test/source/basic/kafka\*.slt 2> $LOGDIR/source-{}.log && rm $LOGDIR/source-{}.log'
+seq "$TEST_NUM" | parallel './risingwave_simulation --kafka-datadir=./scripts/source/test_data ./e2e_test/source_legacy/basic/kafka\*.slt 2> $LOGDIR/source-{}.log && rm $LOGDIR/source-{}.log'
 
 echo "--- deterministic simulation e2e, ci-3cn-2fe, parallel, streaming"
 seq "$TEST_NUM" | parallel './risingwave_simulation -j 16 ./e2e_test/streaming/\*\*/\*.slt 2> $LOGDIR/parallel-streaming-{}.log && rm $LOGDIR/parallel-streaming-{}.log'
diff --git a/ci/scripts/deterministic-recovery-test.sh b/ci/scripts/deterministic-recovery-test.sh
index b38adfb3a83da..62d2250af96ec 100755
--- a/ci/scripts/deterministic-recovery-test.sh
+++ b/ci/scripts/deterministic-recovery-test.sh
@@ -95,4 +95,4 @@ seq "$TEST_NUM" | parallel './risingwave_simulation \
 --kill-rate=${KILL_RATE} \
 --kafka-datadir=./scripts/source/test_data \
 ${EXTRA_ARGS:-} \
-./e2e_test/source/basic/kafka\*.slt 2> $LOGDIR/recovery-source-{}.log && rm $LOGDIR/recovery-source-{}.log'
\ No newline at end of file
+./e2e_test/source_legacy/basic/kafka\*.slt 2> $LOGDIR/recovery-source-{}.log && rm $LOGDIR/recovery-source-{}.log'
diff --git a/ci/scripts/e2e-sink-test.sh b/ci/scripts/e2e-sink-test.sh
index 5e4685b2fc67a..0a049f828619d 100755
--- a/ci/scripts/e2e-sink-test.sh
+++ b/ci/scripts/e2e-sink-test.sh
@@ -124,8 +124,8 @@ risedev ci-kill
 echo "--- e2e, ci-1cn-1fe, nexmark endless"
 RUST_LOG="info,risingwave_stream=info,risingwave_batch=info,risingwave_storage=info" \
 risedev ci-start ci-1cn-1fe
-sqllogictest -p 4566 -d dev './e2e_test/source/nexmark_endless_mvs/*.slt'
-sqllogictest -p 4566 -d dev './e2e_test/source/nexmark_endless_sinks/*.slt'
+sqllogictest -p 4566 -d dev './e2e_test/source_legacy/nexmark_endless_mvs/*.slt'
+sqllogictest -p 4566 -d dev './e2e_test/source_legacy/nexmark_endless_sinks/*.slt'
 
 echo "--- Kill cluster"
 risedev ci-kill
diff --git a/ci/scripts/e2e-source-test.sh b/ci/scripts/e2e-source-test.sh
index f10ee3ebef091..5c53f84c24858 100755
--- a/ci/scripts/e2e-source-test.sh
+++ b/ci/scripts/e2e-source-test.sh
@@ -51,12 +51,12 @@ cp src/connector/src/test_data/complex-schema.json ./json-complex-schema
 echo "--- e2e, ci-1cn-1fe, mysql & postgres cdc"
 
 # import data to mysql
-mysql --host=mysql --port=3306 -u root -p123456 < ./e2e_test/source/cdc/mysql_cdc.sql
+mysql --host=mysql --port=3306 -u root -p123456 < ./e2e_test/source_legacy/cdc/mysql_cdc.sql
 
 # import data to postgres
 export PGHOST=db PGPORT=5432 PGUSER=postgres PGPASSWORD=postgres PGDATABASE=cdc_test
 createdb
-psql < ./e2e_test/source/cdc/postgres_cdc.sql
+psql < ./e2e_test/source_legacy/cdc/postgres_cdc.sql
 
 echo "--- starting risingwave cluster"
 RUST_LOG="debug,risingwave_stream=info,risingwave_batch=info,risingwave_storage=info" \
@@ -82,30 +82,30 @@ echo 'db.runCommand({ping: 1})' | mongo mongodb://mongodb:27017
 echo '> rs config'
 echo 'rs.conf()' | mongo mongodb://mongodb:27017
 echo '> run test..'
-risedev slt './e2e_test/source/cdc/mongodb/**/*.slt'
+risedev slt './e2e_test/source_legacy/cdc/mongodb/**/*.slt'
 
 echo "--- inline cdc test"
 export MYSQL_HOST=mysql MYSQL_TCP_PORT=3306 MYSQL_PWD=123456
 export SQLCMDSERVER=sqlserver-server SQLCMDUSER=SA SQLCMDPASSWORD="SomeTestOnly@SA" SQLCMDDBNAME=mydb SQLCMDPORT=1433
-risedev slt './e2e_test/source/cdc_inline/**/*.slt'
+risedev slt './e2e_test/source_legacy/cdc_inline/**/*.slt'
 
 echo "--- opendal source test"
-risedev slt './e2e_test/source/opendal/**/*.slt'
+risedev slt './e2e_test/source_legacy/opendal/**/*.slt'
 
 echo "--- mysql & postgres cdc validate test"
-risedev slt './e2e_test/source/cdc/cdc.validate.mysql.slt'
-risedev slt './e2e_test/source/cdc/cdc.validate.postgres.slt'
+risedev slt './e2e_test/source_legacy/cdc/cdc.validate.mysql.slt'
+risedev slt './e2e_test/source_legacy/cdc/cdc.validate.postgres.slt'
 
 echo "--- cdc share source test"
 # cdc share stream test cases
 export MYSQL_HOST=mysql MYSQL_TCP_PORT=3306 MYSQL_PWD=123456
-risedev slt './e2e_test/source/cdc/cdc.share_stream.slt'
+risedev slt './e2e_test/source_legacy/cdc/cdc.share_stream.slt'
 
 echo "--- mysql & postgres load and check"
-risedev slt './e2e_test/source/cdc/cdc.load.slt'
+risedev slt './e2e_test/source_legacy/cdc/cdc.load.slt'
 # wait for cdc loading
 sleep 10
-risedev slt './e2e_test/source/cdc/cdc.check.slt'
+risedev slt './e2e_test/source_legacy/cdc/cdc.check.slt'
 
 # kill cluster
 risedev kill
@@ -121,10 +121,10 @@ mysql --protocol=tcp -u root mytest -e "INSERT INTO products
 
 
 # insert new rows
-mysql --host=mysql --port=3306 -u root -p123456 < ./e2e_test/source/cdc/mysql_cdc_insert.sql
+mysql --host=mysql --port=3306 -u root -p123456 < ./e2e_test/source_legacy/cdc/mysql_cdc_insert.sql
 echo "> inserted new rows into mysql"
 
-psql < ./e2e_test/source/cdc/postgres_cdc_insert.sql
+psql < ./e2e_test/source_legacy/cdc/postgres_cdc_insert.sql
 echo "> inserted new rows into postgres"
 
 # start cluster w/o clean-data
@@ -136,13 +136,13 @@ echo "> wait for cluster recovery finish"
 sleep 20
 echo "> check mviews after cluster recovery"
 # check results
-risedev slt './e2e_test/source/cdc/cdc.check_new_rows.slt'
+risedev slt './e2e_test/source_legacy/cdc/cdc.check_new_rows.slt'
 
 # drop relations
-risedev slt './e2e_test/source/cdc/cdc_share_stream_drop.slt'
+risedev slt './e2e_test/source_legacy/cdc/cdc_share_stream_drop.slt'
 
 echo "--- postgres_query tvf test"
-risedev slt './e2e_test/source/tvf/postgres_query.slt'
+risedev slt './e2e_test/source_legacy/tvf/postgres_query.slt'
 
 echo "--- Kill cluster"
 risedev ci-kill
@@ -153,8 +153,8 @@ export RUST_MIN_STACK=4194304
 RUST_LOG="info,risingwave_stream=info,risingwave_batch=info,risingwave_storage=info" \
 risedev ci-start ci-kafka
 ./scripts/source/prepare_ci_kafka.sh
-risedev slt './e2e_test/source/basic/*.slt'
-risedev slt './e2e_test/source/basic/old_row_format_syntax/*.slt'
+risedev slt './e2e_test/source_legacy/basic/*.slt'
+risedev slt './e2e_test/source_legacy/basic/old_row_format_syntax/*.slt'
 
 echo "--- Run CH-benCHmark"
 risedev slt './e2e_test/ch_benchmark/batch/ch_benchmark.slt'
diff --git a/ci/scripts/pulsar-source-test.sh b/ci/scripts/pulsar-source-test.sh
index 86d99ed97f7d2..dfe8aa28005af 100755
--- a/ci/scripts/pulsar-source-test.sh
+++ b/ci/scripts/pulsar-source-test.sh
@@ -46,8 +46,8 @@ risedev ci-start ci-1cn-1fe
 
 echo "--- Run test"
 python3 -m pip install --break-system-packages psycopg2-binary
-python3 e2e_test/source/pulsar/astra-streaming.py
-# python3 e2e_test/source/pulsar/streamnative-cloud.py
+python3 e2e_test/source_legacy/pulsar/astra-streaming.py
+# python3 e2e_test/source_legacy/pulsar/streamnative-cloud.py
 
 echo "--- Kill cluster"
 risedev ci-kill
diff --git a/e2e_test/ddl/throttle.slt b/e2e_test/ddl/throttle.slt
index e8a33b0bfb433..65fa126dbd203 100644
--- a/e2e_test/ddl/throttle.slt
+++ b/e2e_test/ddl/throttle.slt
@@ -1,5 +1,5 @@
 # streaming_rate_limit applies to create source, please refer to
-# e2e_test/source/basic/kafka.slt.
+# e2e_test/source_legacy/basic/kafka.slt.
 # backfill_rate_limit applies to create sink, please refer to
 # e2e_test/sink/kafka/create_sink.slt.
 
diff --git a/e2e_test/source/README.md b/e2e_test/source_legacy/README.md
similarity index 100%
rename from e2e_test/source/README.md
rename to e2e_test/source_legacy/README.md
diff --git a/e2e_test/source/basic/datagen.slt b/e2e_test/source_legacy/basic/datagen.slt
similarity index 100%
rename from e2e_test/source/basic/datagen.slt
rename to e2e_test/source_legacy/basic/datagen.slt
diff --git a/e2e_test/source/basic/ddl.slt b/e2e_test/source_legacy/basic/ddl.slt
similarity index 100%
rename from e2e_test/source/basic/ddl.slt
rename to e2e_test/source_legacy/basic/ddl.slt
diff --git a/e2e_test/source/basic/handling_mode.slt b/e2e_test/source_legacy/basic/handling_mode.slt
similarity index 100%
rename from e2e_test/source/basic/handling_mode.slt
rename to e2e_test/source_legacy/basic/handling_mode.slt
diff --git a/e2e_test/source/basic/kafka.slt b/e2e_test/source_legacy/basic/kafka.slt
similarity index 100%
rename from e2e_test/source/basic/kafka.slt
rename to e2e_test/source_legacy/basic/kafka.slt
diff --git a/e2e_test/source/basic/kafka_batch.slt b/e2e_test/source_legacy/basic/kafka_batch.slt
similarity index 100%
rename from e2e_test/source/basic/kafka_batch.slt
rename to e2e_test/source_legacy/basic/kafka_batch.slt
diff --git a/e2e_test/source/basic/kinesis.slt b/e2e_test/source_legacy/basic/kinesis.slt
similarity index 100%
rename from e2e_test/source/basic/kinesis.slt
rename to e2e_test/source_legacy/basic/kinesis.slt
diff --git a/e2e_test/source/basic/nexmark/nexmark_endless_part1.slt.part b/e2e_test/source_legacy/basic/nexmark/nexmark_endless_part1.slt.part
similarity index 100%
rename from e2e_test/source/basic/nexmark/nexmark_endless_part1.slt.part
rename to e2e_test/source_legacy/basic/nexmark/nexmark_endless_part1.slt.part
diff --git a/e2e_test/source/basic/nosim_kafka.slt b/e2e_test/source_legacy/basic/nosim_kafka.slt
similarity index 100%
rename from e2e_test/source/basic/nosim_kafka.slt
rename to e2e_test/source_legacy/basic/nosim_kafka.slt
diff --git a/e2e_test/source/basic/old_row_format_syntax/datagen.slt b/e2e_test/source_legacy/basic/old_row_format_syntax/datagen.slt
similarity index 100%
rename from e2e_test/source/basic/old_row_format_syntax/datagen.slt
rename to e2e_test/source_legacy/basic/old_row_format_syntax/datagen.slt
diff --git a/e2e_test/source/basic/old_row_format_syntax/ddl.slt b/e2e_test/source_legacy/basic/old_row_format_syntax/ddl.slt
similarity index 100%
rename from e2e_test/source/basic/old_row_format_syntax/ddl.slt
rename to e2e_test/source_legacy/basic/old_row_format_syntax/ddl.slt
diff --git a/e2e_test/source/basic/old_row_format_syntax/kafka.slt b/e2e_test/source_legacy/basic/old_row_format_syntax/kafka.slt
similarity index 100%
rename from e2e_test/source/basic/old_row_format_syntax/kafka.slt
rename to e2e_test/source_legacy/basic/old_row_format_syntax/kafka.slt
diff --git a/e2e_test/source/basic/old_row_format_syntax/kafka_batch.slt b/e2e_test/source_legacy/basic/old_row_format_syntax/kafka_batch.slt
similarity index 99%
rename from e2e_test/source/basic/old_row_format_syntax/kafka_batch.slt
rename to e2e_test/source_legacy/basic/old_row_format_syntax/kafka_batch.slt
index 44f40b90c08c4..ebf63123c5ddb 100644
--- a/e2e_test/source/basic/old_row_format_syntax/kafka_batch.slt
+++ b/e2e_test/source_legacy/basic/old_row_format_syntax/kafka_batch.slt
@@ -201,4 +201,4 @@ statement ok
 drop table s8
 
 statement ok
-drop source s9
\ No newline at end of file
+drop source s9
diff --git a/e2e_test/source/basic/temporary_kafka_batch.slt b/e2e_test/source_legacy/basic/temporary_kafka_batch.slt
similarity index 100%
rename from e2e_test/source/basic/temporary_kafka_batch.slt
rename to e2e_test/source_legacy/basic/temporary_kafka_batch.slt
diff --git a/e2e_test/source/basic/ttl_table_with_con.slt b/e2e_test/source_legacy/basic/ttl_table_with_con.slt
similarity index 97%
rename from e2e_test/source/basic/ttl_table_with_con.slt
rename to e2e_test/source_legacy/basic/ttl_table_with_con.slt
index 6a232bbdee2a2..14869634d782d 100644
--- a/e2e_test/source/basic/ttl_table_with_con.slt
+++ b/e2e_test/source_legacy/basic/ttl_table_with_con.slt
@@ -29,4 +29,4 @@ select * from t;
 ----
 
 statement ok
-drop table t;
\ No newline at end of file
+drop table t;
diff --git a/e2e_test/source/cdc/cdc.check.slt b/e2e_test/source_legacy/cdc/cdc.check.slt
similarity index 100%
rename from e2e_test/source/cdc/cdc.check.slt
rename to e2e_test/source_legacy/cdc/cdc.check.slt
diff --git a/e2e_test/source/cdc/cdc.check_new_rows.slt b/e2e_test/source_legacy/cdc/cdc.check_new_rows.slt
similarity index 100%
rename from e2e_test/source/cdc/cdc.check_new_rows.slt
rename to e2e_test/source_legacy/cdc/cdc.check_new_rows.slt
diff --git a/e2e_test/source/cdc/cdc.load.slt b/e2e_test/source_legacy/cdc/cdc.load.slt
similarity index 100%
rename from e2e_test/source/cdc/cdc.load.slt
rename to e2e_test/source_legacy/cdc/cdc.load.slt
diff --git a/e2e_test/source/cdc/cdc.share_stream.slt b/e2e_test/source_legacy/cdc/cdc.share_stream.slt
similarity index 98%
rename from e2e_test/source/cdc/cdc.share_stream.slt
rename to e2e_test/source_legacy/cdc/cdc.share_stream.slt
index c8fcfecb5a8b0..a2de0a5e8168d 100644
--- a/e2e_test/source/cdc/cdc.share_stream.slt
+++ b/e2e_test/source_legacy/cdc/cdc.share_stream.slt
@@ -5,11 +5,11 @@ system ok
 mysql --protocol=tcp -u root -e "DROP DATABASE IF EXISTS mytest; CREATE DATABASE mytest;"
 
 system ok
-mysql --protocol=tcp -u root mytest < e2e_test/source/cdc/mysql_create.sql
+mysql --protocol=tcp -u root mytest < e2e_test/source_legacy/cdc/mysql_create.sql
 
 # generate data to mysql
 system ok
-mysql --protocol=tcp -u root mytest < e2e_test/source/cdc/mysql_init_data.sql
+mysql --protocol=tcp -u root mytest < e2e_test/source_legacy/cdc/mysql_init_data.sql
 
 statement ok
 create secret mysql_pwd with (
diff --git a/e2e_test/source/cdc/cdc.validate.mysql.slt b/e2e_test/source_legacy/cdc/cdc.validate.mysql.slt
similarity index 100%
rename from e2e_test/source/cdc/cdc.validate.mysql.slt
rename to e2e_test/source_legacy/cdc/cdc.validate.mysql.slt
diff --git a/e2e_test/source/cdc/cdc.validate.postgres.slt b/e2e_test/source_legacy/cdc/cdc.validate.postgres.slt
similarity index 100%
rename from e2e_test/source/cdc/cdc.validate.postgres.slt
rename to e2e_test/source_legacy/cdc/cdc.validate.postgres.slt
diff --git a/e2e_test/source/cdc/cdc_share_stream_drop.slt b/e2e_test/source_legacy/cdc/cdc_share_stream_drop.slt
similarity index 100%
rename from e2e_test/source/cdc/cdc_share_stream_drop.slt
rename to e2e_test/source_legacy/cdc/cdc_share_stream_drop.slt
diff --git a/e2e_test/source/cdc/mongodb/mongodb_basic.slt b/e2e_test/source_legacy/cdc/mongodb/mongodb_basic.slt
similarity index 100%
rename from e2e_test/source/cdc/mongodb/mongodb_basic.slt
rename to e2e_test/source_legacy/cdc/mongodb/mongodb_basic.slt
diff --git a/e2e_test/source/cdc/mysql_cdc.sql b/e2e_test/source_legacy/cdc/mysql_cdc.sql
similarity index 100%
rename from e2e_test/source/cdc/mysql_cdc.sql
rename to e2e_test/source_legacy/cdc/mysql_cdc.sql
diff --git a/e2e_test/source/cdc/mysql_cdc_insert.sql b/e2e_test/source_legacy/cdc/mysql_cdc_insert.sql
similarity index 100%
rename from e2e_test/source/cdc/mysql_cdc_insert.sql
rename to e2e_test/source_legacy/cdc/mysql_cdc_insert.sql
diff --git a/e2e_test/source/cdc/mysql_create.sql b/e2e_test/source_legacy/cdc/mysql_create.sql
similarity index 100%
rename from e2e_test/source/cdc/mysql_create.sql
rename to e2e_test/source_legacy/cdc/mysql_create.sql
diff --git a/e2e_test/source/cdc/mysql_init_data.sql b/e2e_test/source_legacy/cdc/mysql_init_data.sql
similarity index 100%
rename from e2e_test/source/cdc/mysql_init_data.sql
rename to e2e_test/source_legacy/cdc/mysql_init_data.sql
diff --git a/e2e_test/source/cdc/postgres_cdc.sql b/e2e_test/source_legacy/cdc/postgres_cdc.sql
similarity index 100%
rename from e2e_test/source/cdc/postgres_cdc.sql
rename to e2e_test/source_legacy/cdc/postgres_cdc.sql
diff --git a/e2e_test/source/cdc/postgres_cdc_insert.sql b/e2e_test/source_legacy/cdc/postgres_cdc_insert.sql
similarity index 100%
rename from e2e_test/source/cdc/postgres_cdc_insert.sql
rename to e2e_test/source_legacy/cdc/postgres_cdc_insert.sql
diff --git a/e2e_test/source/cdc_inline/alter/cdc_backfill_rate_limit.slt b/e2e_test/source_legacy/cdc_inline/alter/cdc_backfill_rate_limit.slt
similarity index 100%
rename from e2e_test/source/cdc_inline/alter/cdc_backfill_rate_limit.slt
rename to e2e_test/source_legacy/cdc_inline/alter/cdc_backfill_rate_limit.slt
diff --git a/e2e_test/source/cdc_inline/alter/cdc_table_alter.slt b/e2e_test/source_legacy/cdc_inline/alter/cdc_table_alter.slt
similarity index 100%
rename from e2e_test/source/cdc_inline/alter/cdc_table_alter.slt
rename to e2e_test/source_legacy/cdc_inline/alter/cdc_table_alter.slt
diff --git a/e2e_test/source/cdc_inline/alter/postgres_alter.slt b/e2e_test/source_legacy/cdc_inline/alter/postgres_alter.slt
similarity index 100%
rename from e2e_test/source/cdc_inline/alter/postgres_alter.slt
rename to e2e_test/source_legacy/cdc_inline/alter/postgres_alter.slt
diff --git a/e2e_test/source/cdc_inline/auto_schema_change_mysql.slt b/e2e_test/source_legacy/cdc_inline/auto_schema_change_mysql.slt
similarity index 100%
rename from e2e_test/source/cdc_inline/auto_schema_change_mysql.slt
rename to e2e_test/source_legacy/cdc_inline/auto_schema_change_mysql.slt
diff --git a/e2e_test/source/cdc_inline/auto_schema_map_mysql.slt b/e2e_test/source_legacy/cdc_inline/auto_schema_map_mysql.slt
similarity index 100%
rename from e2e_test/source/cdc_inline/auto_schema_map_mysql.slt
rename to e2e_test/source_legacy/cdc_inline/auto_schema_map_mysql.slt
diff --git a/e2e_test/source/cdc_inline/auto_schema_map_pg.slt b/e2e_test/source_legacy/cdc_inline/auto_schema_map_pg.slt
similarity index 100%
rename from e2e_test/source/cdc_inline/auto_schema_map_pg.slt
rename to e2e_test/source_legacy/cdc_inline/auto_schema_map_pg.slt
diff --git a/e2e_test/source/cdc_inline/postgres_create_drop.slt b/e2e_test/source_legacy/cdc_inline/postgres_create_drop.slt
similarity index 98%
rename from e2e_test/source/cdc_inline/postgres_create_drop.slt
rename to e2e_test/source_legacy/cdc_inline/postgres_create_drop.slt
index ad7425bab3df9..f23ff824f249f 100644
--- a/e2e_test/source/cdc_inline/postgres_create_drop.slt
+++ b/e2e_test/source_legacy/cdc_inline/postgres_create_drop.slt
@@ -57,4 +57,4 @@ SELECT * FROM tt1;
 1 2023-10-23 10:00:00+00:00
 
 statement ok
-drop table tt1;
\ No newline at end of file
+drop table tt1;
diff --git a/e2e_test/source/cdc_inline/sql_server_cdc/sql_server_cdc.slt b/e2e_test/source_legacy/cdc_inline/sql_server_cdc/sql_server_cdc.slt
similarity index 98%
rename from e2e_test/source/cdc_inline/sql_server_cdc/sql_server_cdc.slt
rename to e2e_test/source_legacy/cdc_inline/sql_server_cdc/sql_server_cdc.slt
index ee78060a814cc..75adae3a04d90 100644
--- a/e2e_test/source/cdc_inline/sql_server_cdc/sql_server_cdc.slt
+++ b/e2e_test/source_legacy/cdc_inline/sql_server_cdc/sql_server_cdc.slt
@@ -9,7 +9,7 @@ system ok
 sqlcmd -C -d master -Q 'create database UpperDB COLLATE SQL_Latin1_General_CP1_CS_AS;' -b
 
 system ok
-sqlcmd -C -i e2e_test/source/cdc_inline/sql_server_cdc/sql_server_cdc_prepare.sql -b
+sqlcmd -C -i e2e_test/source_legacy/cdc_inline/sql_server_cdc/sql_server_cdc_prepare.sql -b
 
 system ok
 sqlcmd -C -d UpperDB -Q "CREATE SCHEMA UpperSchema;" -b
@@ -418,7 +418,7 @@ SELECT id, c_xml from shared_sqlserver_all_data_types order by id;
 
 # ------------ add rows stage ------------
 system ok
-sqlcmd -C -i e2e_test/source/cdc_inline/sql_server_cdc/sql_server_cdc_insert.sql -b
+sqlcmd -C -i e2e_test/source_legacy/cdc_inline/sql_server_cdc/sql_server_cdc_insert.sql -b
 
 system ok
 sqlcmd -C -d UpperDB -Q "INSERT INTO UpperSchema.UpperTable VALUES (11, 'Alice');" -b
diff --git a/e2e_test/source/cdc_inline/sql_server_cdc/sql_server_cdc_insert.sql b/e2e_test/source_legacy/cdc_inline/sql_server_cdc/sql_server_cdc_insert.sql
similarity index 100%
rename from e2e_test/source/cdc_inline/sql_server_cdc/sql_server_cdc_insert.sql
rename to e2e_test/source_legacy/cdc_inline/sql_server_cdc/sql_server_cdc_insert.sql
diff --git a/e2e_test/source/cdc_inline/sql_server_cdc/sql_server_cdc_prepare.sql b/e2e_test/source_legacy/cdc_inline/sql_server_cdc/sql_server_cdc_prepare.sql
similarity index 100%
rename from e2e_test/source/cdc_inline/sql_server_cdc/sql_server_cdc_prepare.sql
rename to e2e_test/source_legacy/cdc_inline/sql_server_cdc/sql_server_cdc_prepare.sql
diff --git a/e2e_test/source/nexmark_endless_mvs/nexmark_endless_part1.slt b/e2e_test/source_legacy/nexmark_endless_mvs/nexmark_endless_part1.slt
similarity index 100%
rename from e2e_test/source/nexmark_endless_mvs/nexmark_endless_part1.slt
rename to e2e_test/source_legacy/nexmark_endless_mvs/nexmark_endless_part1.slt
diff --git a/e2e_test/source/nexmark_endless_mvs/nexmark_endless_part2.slt b/e2e_test/source_legacy/nexmark_endless_mvs/nexmark_endless_part2.slt
similarity index 100%
rename from e2e_test/source/nexmark_endless_mvs/nexmark_endless_part2.slt
rename to e2e_test/source_legacy/nexmark_endless_mvs/nexmark_endless_part2.slt
diff --git a/e2e_test/source/nexmark_endless_mvs/nexmark_endless_part3.slt b/e2e_test/source_legacy/nexmark_endless_mvs/nexmark_endless_part3.slt
similarity index 100%
rename from e2e_test/source/nexmark_endless_mvs/nexmark_endless_part3.slt
rename to e2e_test/source_legacy/nexmark_endless_mvs/nexmark_endless_part3.slt
diff --git a/e2e_test/source/nexmark_endless_mvs/nexmark_endless_part4.slt b/e2e_test/source_legacy/nexmark_endless_mvs/nexmark_endless_part4.slt
similarity index 100%
rename from e2e_test/source/nexmark_endless_mvs/nexmark_endless_part4.slt
rename to e2e_test/source_legacy/nexmark_endless_mvs/nexmark_endless_part4.slt
diff --git a/e2e_test/source/nexmark_endless_sinks/nexmark_endless_part1.slt b/e2e_test/source_legacy/nexmark_endless_sinks/nexmark_endless_part1.slt
similarity index 100%
rename from e2e_test/source/nexmark_endless_sinks/nexmark_endless_part1.slt
rename to e2e_test/source_legacy/nexmark_endless_sinks/nexmark_endless_part1.slt
diff --git a/e2e_test/source/nexmark_endless_sinks/nexmark_endless_part2.slt b/e2e_test/source_legacy/nexmark_endless_sinks/nexmark_endless_part2.slt
similarity index 100%
rename from e2e_test/source/nexmark_endless_sinks/nexmark_endless_part2.slt
rename to e2e_test/source_legacy/nexmark_endless_sinks/nexmark_endless_part2.slt
diff --git a/e2e_test/source/nexmark_endless_sinks/nexmark_endless_part3.slt b/e2e_test/source_legacy/nexmark_endless_sinks/nexmark_endless_part3.slt
similarity index 100%
rename from e2e_test/source/nexmark_endless_sinks/nexmark_endless_part3.slt
rename to e2e_test/source_legacy/nexmark_endless_sinks/nexmark_endless_part3.slt
diff --git a/e2e_test/source/nexmark_endless_sinks/nexmark_endless_part4.slt b/e2e_test/source_legacy/nexmark_endless_sinks/nexmark_endless_part4.slt
similarity index 100%
rename from e2e_test/source/nexmark_endless_sinks/nexmark_endless_part4.slt
rename to e2e_test/source_legacy/nexmark_endless_sinks/nexmark_endless_part4.slt
diff --git a/e2e_test/source/nexmark_endless_sinks/nexmark_endless_part5.slt b/e2e_test/source_legacy/nexmark_endless_sinks/nexmark_endless_part5.slt
similarity index 100%
rename from e2e_test/source/nexmark_endless_sinks/nexmark_endless_part5.slt
rename to e2e_test/source_legacy/nexmark_endless_sinks/nexmark_endless_part5.slt
diff --git a/e2e_test/source/nexmark_endless_sinks/nexmark_endless_part6.slt b/e2e_test/source_legacy/nexmark_endless_sinks/nexmark_endless_part6.slt
similarity index 100%
rename from e2e_test/source/nexmark_endless_sinks/nexmark_endless_part6.slt
rename to e2e_test/source_legacy/nexmark_endless_sinks/nexmark_endless_part6.slt
diff --git a/e2e_test/source/opendal/data/data1.csv b/e2e_test/source_legacy/opendal/data/data1.csv
similarity index 100%
rename from e2e_test/source/opendal/data/data1.csv
rename to e2e_test/source_legacy/opendal/data/data1.csv
diff --git a/e2e_test/source/opendal/data/data2.csv b/e2e_test/source_legacy/opendal/data/data2.csv
similarity index 100%
rename from e2e_test/source/opendal/data/data2.csv
rename to e2e_test/source_legacy/opendal/data/data2.csv
diff --git a/e2e_test/source/opendal/posix_fs.slt b/e2e_test/source_legacy/opendal/posix_fs.slt
similarity index 90%
rename from e2e_test/source/opendal/posix_fs.slt
rename to e2e_test/source_legacy/opendal/posix_fs.slt
index 8eb1ce665590d..88cc57df16ccd 100644
--- a/e2e_test/source/opendal/posix_fs.slt
+++ b/e2e_test/source_legacy/opendal/posix_fs.slt
@@ -10,7 +10,7 @@ CREATE TABLE diamonds (
 ) WITH (
     connector = 'posix_fs',
     match_pattern = 'data*.csv',
-    posix_fs.root = 'e2e_test/source/opendal/data',
+    posix_fs.root = 'e2e_test/source_legacy/opendal/data',
 ) FORMAT PLAIN ENCODE CSV ( without_header = 'false', delimiter = ',');
 
 sleep 10s
diff --git a/e2e_test/source/pulsar/astra-streaming.py b/e2e_test/source_legacy/pulsar/astra-streaming.py
similarity index 92%
rename from e2e_test/source/pulsar/astra-streaming.py
rename to e2e_test/source_legacy/pulsar/astra-streaming.py
index b2e653ed5677b..97cf9fd839892 100644
--- a/e2e_test/source/pulsar/astra-streaming.py
+++ b/e2e_test/source_legacy/pulsar/astra-streaming.py
@@ -29,7 +29,7 @@ def do_test(config):
 
     # Do test with slt
     ret = os.system(
-        "sqllogictest -p 4566 -d dev './e2e_test/source/pulsar/pulsar.slt'")
+        "sqllogictest -p 4566 -d dev './e2e_test/source_legacy/pulsar/pulsar.slt'")
     # Clean up
     cur.execute('drop table t')
 
diff --git a/e2e_test/source/pulsar/pulsar.slt b/e2e_test/source_legacy/pulsar/pulsar.slt
similarity index 100%
rename from e2e_test/source/pulsar/pulsar.slt
rename to e2e_test/source_legacy/pulsar/pulsar.slt
diff --git a/e2e_test/source/pulsar/streamnative-cloud.py b/e2e_test/source_legacy/pulsar/streamnative-cloud.py
similarity index 94%
rename from e2e_test/source/pulsar/streamnative-cloud.py
rename to e2e_test/source_legacy/pulsar/streamnative-cloud.py
index f4fad0804fd02..0ca4f3e5641e8 100644
--- a/e2e_test/source/pulsar/streamnative-cloud.py
+++ b/e2e_test/source_legacy/pulsar/streamnative-cloud.py
@@ -33,7 +33,7 @@ def do_test(config):
 
     # Do test with slt
     ret = os.system(
-        "sqllogictest -p 4566 -d dev './e2e_test/source/pulsar/pulsar.slt'")
+        "sqllogictest -p 4566 -d dev './e2e_test/source_legacy/pulsar/pulsar.slt'")
     # Clean up
     cur.execute('drop table t')
 
diff --git a/e2e_test/source/tvf/postgres_query.slt b/e2e_test/source_legacy/tvf/postgres_query.slt
similarity index 97%
rename from e2e_test/source/tvf/postgres_query.slt
rename to e2e_test/source_legacy/tvf/postgres_query.slt
index 566ace0409a1a..0ce577535b923 100644
--- a/e2e_test/source/tvf/postgres_query.slt
+++ b/e2e_test/source_legacy/tvf/postgres_query.slt
@@ -37,4 +37,4 @@ select * from postgres_query('db', '5432', 'postgres', 'postgres', 'cdc_test', '
 97 t 1 1 1 1 1 1.0 2021-01-01 00:00:00 2021-01-01 00:00:00 2021-01-01 08:00:00+00:00 text varchar 1 day {} \x01
 98 t 1 1 1 1 1 1.0 2021-01-01 00:00:00 2021-01-01 00:00:00 2021-01-01 08:00:00+00:00 text varchar 1 day {} \x01
 99 t 1 1 1 1 1 1.0 2021-01-01 00:00:00 2021-01-01 00:00:00 2021-01-01 08:00:00+00:00 text varchar 1 day {} \x01
-100 t 1 1 1 1 1 1.0 2021-01-01 00:00:00 2021-01-01 00:00:00 2021-01-01 08:00:00+00:00 text varchar 1 day {} \x01
\ No newline at end of file
+100 t 1 1 1 1 1 1.0 2021-01-01 00:00:00 2021-01-01 00:00:00 2021-01-01 08:00:00+00:00 text varchar 1 day {} \x01