cancel
Showing results for 
Search instead for 
Did you mean: 
yit337
Contributor
since ‎01-21-2026
2 weeks ago

User Stats

  • 21 Posts
  • 0 Solutions
  • 11 Kudos given
  • 3 Kudos received

User Activity

I've got a fact streaming table, which is updated by SCD2 records from the CDF of a silver table. The join is on pk  (hash key generated from dimensions business keys) and factory_code (60 unique values). On each incremental processing, it reads all ...
I use Lakeflow Connect to load data from my source databases to bronze tables. Then I have auto_cdc to track SCD2 changes in my silver tables. I use _commit_timestamp from the bronze CDF, as sequence_by property in auto_cdc in order to order the vers...
I read somewhere that there's a max_concurrent_task_runs property, but can't find it anywhere in the docs. So, how to limit the maximum concurrent tasks run in a job?
As the subject states, my question is:Is it required to run the Ingestion Pipeline in Lakeflow Connect on Serverless compute? Cause I try to define my own cluster in the DAB, but it raises an error:`Error: cannot create pipeline: You cannot provide c...
I have a stream to static join, but some of the rows in the static table arrive later than the linked rows in the stream.What is the default behaviour if a record in the stream hasn't joined a record in the static table? Is it lost forever?How is thi...