Skip to main content

Hi 

I have the following orchestrating job:

 

The purpose of this pipeline is to first synchronize a list of tables via a full load between Oracle and Snowflake. After that, the CDC sync is started for each table passing the SCN that was read at the beginning. All jobs are executed in the background, so we can take advantage of running in parallel.

 

In the first step (SCN & Tables) I extract a list of tables and SCN and batch sizes. The output looks like this:

 

TableName

 SCN BatchSize
Table1 123321 100
Table2 123321 100
Table3 123321 500
... ... ...

 

Then this list is passed to step 3 (Start Bulk Load) and everything works as expected.

Step 3 starts per row a job. I have activated the option "Run In Background".

Here the expression of the parameters I’m passing in this step:

 

p{"tablename":"${record:value("/TABLENAME")}","batchsize":"${record:value("/BATCHSIZE")}"}

 

Then the same list is passed in step 5 (Start Oracle CDC) but only the first job of the table is created.

 

I also noticed this in job summary of step 3:

I have 8 tables in my test case

 

So I assume that after step 3, the collection of ${record:value("/TABLENAME")} is reduced to the first job that is completed in step 3.

Question: Can I somehow preserve the list from step 1 and restore it after step 3?

 

@drozdse1, Can you try setting the batch size as 1 for your Step#1 and see if that makes it work. You will see that your Step#3 is now running 1 table rather than all in background. I hope this does not slow down your whole process.

What is the use case behind this? I assume you have to run this only once. After that your CDC jobs will be running separately in streaming mode to pick up all the changes. 

Reply


Terms & Conditions