fix

risingwavelabs · Apr 16, 2024 · c7d4944 · c7d4944
1 parent 63bc950
commit c7d4944
Show file tree

Hide file tree

Showing 3 changed files with 13 additions and 13 deletions.
diff --git a/e2e_test/source/cdc/cdc.load.slt b/e2e_test/source/cdc/cdc.load.slt
@@ -217,12 +217,12 @@ create table numeric_to_varchar (
   PRIMARY KEY (id)
 ) with (
  connector = 'postgres-cdc',
- hostname = 'db',
- port = '5432',
- username = 'postgres',
- password = 'postgres',
- database.name = 'cdc_test',
+ hostname = '${PGHOST:localhost}',
+ port = '${PGPORT:5432}',
+ username = '${PGUSER:$USER}',
+ password = '${PGPASSWORD:}',
+ database.name = '${PGDATABASE:postgres}',
  schema.name = 'public',
  table.name = 'numeric_table',
  slot.name = 'numeric_to_varchar'
-);
+);
diff --git a/e2e_test/source/cdc/cdc.share_stream.slt b/e2e_test/source/cdc/cdc.share_stream.slt
@@ -274,14 +274,14 @@ CREATE TABLE numeric_to_rw_int256_shared (
     id int,
     num rw_int256,
     PRIMARY KEY (id)
-) FROM pg_mydb TABLE 'public.numeric_table';
+) FROM pg_source TABLE 'public.numeric_table';
 
 statement ok
 CREATE TABLE numeric_to_varchar_shared (
     id int,
     num varchar,
     PRIMARY KEY (id)
-) FROM pg_mydb TABLE 'public.numeric_table';
+) FROM pg_source TABLE 'public.numeric_table';
 
 
 system ok

diff --git a/e2e_test/source/cdc/cdc.validate.postgres.slt b/e2e_test/source/cdc/cdc.validate.postgres.slt
@@ -177,8 +177,8 @@ explain create table numeric_to_rw_int256 (
  connector = 'postgres-cdc',
  hostname = 'db',
  port = '5432',
- username = 'postgres',
- password = 'postgres',
+ username = '${PGUSER:$USER}',
+ password = '${PGPASSWORD:}',
  database.name = 'cdc_test',
  schema.name = 'public',
  table.name = 'numeric_table',
@@ -194,10 +194,10 @@ explain create table numeric_to_varchar (
  connector = 'postgres-cdc',
  hostname = 'db',
  port = '5432',
- username = 'postgres',
- password = 'postgres',
+ username = '${PGUSER:$USER}',
+ password = '${PGPASSWORD:}',
  database.name = 'cdc_test',
  schema.name = 'public',
  table.name = 'numeric_table',
  slot.name = 'numeric_to_varchar'
-);
+);