cancel
Showing results for 
Search instead for 
Did you mean: 
Data Engineering
cancel
Showing results for 
Search instead for 
Did you mean: 

new input sources to a streaming job while retaining the old checkpoint ?

User16826994223
Honored Contributor III

Hello Team, is there any way to add new input sources to a streaming job while retaining the old checkpoint ? I have seen - 

Changes in the number or type (i.e. different source) of input sources

: This is not allowed

 . Want to find out if there is any option to prevent processing data from old sources when an additional source gets added to the streaming job. Input sources are Delta tables in this case.

1 ACCEPTED SOLUTION

Accepted Solutions

User16826994223
Honored Contributor III

No you cannot do this, but often you can start a new checkpoint that starts from the same offsets the old one left off at: https://docs.databricks.com/delta/delta-streaming.html#specify-initial-position

View solution in original post

1 REPLY 1

User16826994223
Honored Contributor III

No you cannot do this, but often you can start a new checkpoint that starts from the same offsets the old one left off at: https://docs.databricks.com/delta/delta-streaming.html#specify-initial-position