diff --git a/ci/scripts/e2e-source-test.sh b/ci/scripts/e2e-source-test.sh
index 31ded0b59d4c8..4550579d8fec7 100755
--- a/ci/scripts/e2e-source-test.sh
+++ b/ci/scripts/e2e-source-test.sh
@@ -138,9 +138,6 @@ risedev slt './e2e_test/source_legacy/cdc/cdc.check_new_rows.slt'
 # drop relations
 risedev slt './e2e_test/source_legacy/cdc/cdc_share_stream_drop.slt'
 
-echo "--- postgres_query tvf test"
-risedev slt './e2e_test/source_legacy/tvf/postgres_query.slt'
-
 echo "--- Kill cluster"
 risedev ci-kill
 export RISINGWAVE_CI=true
diff --git a/e2e_test/source_legacy/tvf/postgres_query.slt b/e2e_test/source_inline/tvf/postgres_query.slt
similarity index 79%
rename from e2e_test/source_legacy/tvf/postgres_query.slt
rename to e2e_test/source_inline/tvf/postgres_query.slt
index 0ce577535b923..6bb576feb4c50 100644
--- a/e2e_test/source_legacy/tvf/postgres_query.slt
+++ b/e2e_test/source_inline/tvf/postgres_query.slt
@@ -1,5 +1,8 @@
 system ok
-PGHOST=db PGPORT=5432 PGUSER=postgres PGPASSWORD=postgres PGDATABASE=cdc_test psql -c "
+PGHOST=localhost PGPORT=8432 PGUSER=postgres PGPASSWORD=postgres PGDATABASE=source_test createdb
+
+system ok
+PGHOST=localhost PGPORT=8432 PGUSER=postgres PGPASSWORD=postgres PGDATABASE=source_test psql -c "
 CREATE TABLE test (
     id bigint primary key,
     v1 bool,
@@ -21,12 +24,12 @@ CREATE TABLE test (
 );"
 
 system ok
-PGHOST=db PGPORT=5432 PGUSER=postgres PGPASSWORD=postgres PGDATABASE=cdc_test psql -c "
+PGHOST=localhost PGPORT=8432 PGUSER=postgres PGPASSWORD=postgres PGDATABASE=source_test psql -c "
 INSERT INTO test SELECT generate_series(1, 100), true, 1, 1, 1, 1.0, 1.0, 1.0, '2021-01-01', '00:00:00', '2021-01-01 00:00:00', '2021-01-01 00:00:00 pst', 'text', 'varchar', '1 day', '{}', '\x01';
 "
 
 query II
-select * from postgres_query('db', '5432', 'postgres', 'postgres', 'cdc_test', 'select * from test where id > 90;');
+select * from postgres_query('localhost', '8432', 'postgres', 'postgres', 'source_test', 'select * from test where id > 90;');
 ----
 91 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
 92 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