Skip to content

Commit 072107b

Browse files
committed
Fixed PG loader TaskCreator sample
1 parent dd6d260 commit 072107b

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

connectors/postgres/demo/config/samples/loader/TaskCreator.yml

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2,10 +2,9 @@ jobId: ${jobId}
22
jobType: TASK_CREATOR
33
producerConfig:
44
producerId: RDB_TASK_CREATOR
5-
connectionId: postgresConnection
5+
connectionId: RDBConnection
66
jobs:
77
- table: public.emp
8-
jobPrefix: empLoader-
98
numJobs: 5
109
config: JobConfig.yml
1110
loadQuery: "select * from (select Row_Number() over (order by (select 0)) as RowIndex, * from public.emp) as emps Where emps.RowIndex >= ${start} and emps.RowIndex <= ${end}"

0 commit comments

Comments
 (0)