diff --git a/e2e_test/source_legacy/opendal/data/data1.csv b/e2e_test/source_inline/fs/data/data1.csv
similarity index 100%
rename from e2e_test/source_legacy/opendal/data/data1.csv
rename to e2e_test/source_inline/fs/data/data1.csv
diff --git a/e2e_test/source_legacy/opendal/data/data2.csv b/e2e_test/source_inline/fs/data/data2.csv
similarity index 100%
rename from e2e_test/source_legacy/opendal/data/data2.csv
rename to e2e_test/source_inline/fs/data/data2.csv
diff --git a/e2e_test/source_legacy/opendal/posix_fs.slt b/e2e_test/source_inline/fs/posix_fs.slt
similarity index 90%
rename from e2e_test/source_legacy/opendal/posix_fs.slt
rename to e2e_test/source_inline/fs/posix_fs.slt
index 8eb1ce665590d..f7f461ce34e2d 100644
--- a/e2e_test/source_legacy/opendal/posix_fs.slt
+++ b/e2e_test/source_inline/fs/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_inline/posix_fs/data',
 ) FORMAT PLAIN ENCODE CSV ( without_header = 'false', delimiter = ',');
 
 sleep 10s
diff --git a/e2e_test/source_legacy/nexmark_endless_mvs/nexmark_endless_part1.slt b/e2e_test/source_inline/nexmark_endless_mvs/nexmark_endless_part1.slt
similarity index 100%
rename from e2e_test/source_legacy/nexmark_endless_mvs/nexmark_endless_part1.slt
rename to e2e_test/source_inline/nexmark_endless_mvs/nexmark_endless_part1.slt
diff --git a/e2e_test/source_legacy/nexmark_endless_mvs/nexmark_endless_part2.slt b/e2e_test/source_inline/nexmark_endless_mvs/nexmark_endless_part2.slt
similarity index 100%
rename from e2e_test/source_legacy/nexmark_endless_mvs/nexmark_endless_part2.slt
rename to e2e_test/source_inline/nexmark_endless_mvs/nexmark_endless_part2.slt
diff --git a/e2e_test/source_legacy/nexmark_endless_mvs/nexmark_endless_part3.slt b/e2e_test/source_inline/nexmark_endless_mvs/nexmark_endless_part3.slt
similarity index 100%
rename from e2e_test/source_legacy/nexmark_endless_mvs/nexmark_endless_part3.slt
rename to e2e_test/source_inline/nexmark_endless_mvs/nexmark_endless_part3.slt
diff --git a/e2e_test/source_legacy/nexmark_endless_mvs/nexmark_endless_part4.slt b/e2e_test/source_inline/nexmark_endless_mvs/nexmark_endless_part4.slt
similarity index 100%
rename from e2e_test/source_legacy/nexmark_endless_mvs/nexmark_endless_part4.slt
rename to e2e_test/source_inline/nexmark_endless_mvs/nexmark_endless_part4.slt
diff --git a/e2e_test/source_legacy/nexmark_endless_sinks/nexmark_endless_part1.slt b/e2e_test/source_inline/nexmark_endless_sinks/nexmark_endless_part1.slt
similarity index 100%
rename from e2e_test/source_legacy/nexmark_endless_sinks/nexmark_endless_part1.slt
rename to e2e_test/source_inline/nexmark_endless_sinks/nexmark_endless_part1.slt
diff --git a/e2e_test/source_legacy/nexmark_endless_sinks/nexmark_endless_part2.slt b/e2e_test/source_inline/nexmark_endless_sinks/nexmark_endless_part2.slt
similarity index 100%
rename from e2e_test/source_legacy/nexmark_endless_sinks/nexmark_endless_part2.slt
rename to e2e_test/source_inline/nexmark_endless_sinks/nexmark_endless_part2.slt
diff --git a/e2e_test/source_legacy/nexmark_endless_sinks/nexmark_endless_part3.slt b/e2e_test/source_inline/nexmark_endless_sinks/nexmark_endless_part3.slt
similarity index 100%
rename from e2e_test/source_legacy/nexmark_endless_sinks/nexmark_endless_part3.slt
rename to e2e_test/source_inline/nexmark_endless_sinks/nexmark_endless_part3.slt
diff --git a/e2e_test/source_legacy/nexmark_endless_sinks/nexmark_endless_part4.slt b/e2e_test/source_inline/nexmark_endless_sinks/nexmark_endless_part4.slt
similarity index 100%
rename from e2e_test/source_legacy/nexmark_endless_sinks/nexmark_endless_part4.slt
rename to e2e_test/source_inline/nexmark_endless_sinks/nexmark_endless_part4.slt
diff --git a/e2e_test/source_legacy/nexmark_endless_sinks/nexmark_endless_part5.slt b/e2e_test/source_inline/nexmark_endless_sinks/nexmark_endless_part5.slt
similarity index 100%
rename from e2e_test/source_legacy/nexmark_endless_sinks/nexmark_endless_part5.slt
rename to e2e_test/source_inline/nexmark_endless_sinks/nexmark_endless_part5.slt
diff --git a/e2e_test/source_legacy/nexmark_endless_sinks/nexmark_endless_part6.slt b/e2e_test/source_inline/nexmark_endless_sinks/nexmark_endless_part6.slt
similarity index 100%
rename from e2e_test/source_legacy/nexmark_endless_sinks/nexmark_endless_part6.slt
rename to e2e_test/source_inline/nexmark_endless_sinks/nexmark_endless_part6.slt
diff --git a/e2e_test/source_legacy/basic/nexmark/nexmark_endless_part1.slt.part b/e2e_test/source_legacy/basic/nexmark/nexmark_endless_part1.slt.part
deleted file mode 100644
index 3232f55fe54ec..0000000000000
--- a/e2e_test/source_legacy/basic/nexmark/nexmark_endless_part1.slt.part
+++ /dev/null
@@ -1,46 +0,0 @@
-include ../../../nexmark/create_sources.slt.part
-
-include ../../../streaming/nexmark/views/q3.slt.part
-
-sleep 10s
-
-query I
-select count(*) > 0 from (select * from nexmark_q3 limit 1);
-----
-t
-
-statement ok
-drop materialized view nexmark_q3;
-
-include ../../../nexmark/drop_sources.slt.part
-
-include ../../../nexmark/create_sources.slt.part
-include ../../../streaming/nexmark/views/q4.slt.part
-
-sleep 10s
-
-query I
-select count(*) > 0 from (select * from nexmark_q4 limit 1);
-----
-t
-
-statement ok
-drop materialized view nexmark_q4;
-
-
-include ../../../nexmark/drop_sources.slt.part
-
-include ../../../nexmark/create_sources.slt.part
-include ../../../streaming/nexmark/views/q5.slt.part
-
-sleep 20s
-
-query I
-select count(*) > 0 from (select * from nexmark_q5 limit 1);
-----
-t
-
-statement ok
-drop materialized view nexmark_q5;
-
-include ../../../nexmark/drop_sources.slt.part
diff --git a/e2e_test/source_legacy/basic/scripts/test_data/weiling.1 b/e2e_test/source_legacy/basic/scripts/test_data/weiling.1
deleted file mode 100644
index b0255bb720681..0000000000000
--- a/e2e_test/source_legacy/basic/scripts/test_data/weiling.1
+++ /dev/null
@@ -1 +0,0 @@
-{"v1": 1664267577140960}
\ No newline at end of file