cancel
Showing results forย 
Search instead forย 
Did you mean:ย 
Data Engineering
Join discussions on data engineering best practices, architectures, and optimization strategies within the Databricks Community. Exchange insights and solutions with fellow data engineers.
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