File tree Expand file tree Collapse file tree 1 file changed +10
-0
lines changed
Expand file tree Collapse file tree 1 file changed +10
-0
lines changed Original file line number Diff line number Diff line change @@ -406,6 +406,16 @@ func (s *Server) attachDuckLake(db *sql.DB) error {
406406 }
407407
408408 log .Printf ("Attached DuckLake catalog successfully" )
409+
410+ // Set DuckLake max retry count to handle concurrent connections
411+ // DuckLake uses optimistic concurrency - when multiple connections commit
412+ // simultaneously, they may conflict on snapshot IDs. Default of 10 is too low
413+ // for tools like Fivetran that open many concurrent connections.
414+ if _ , err := db .Exec ("SET ducklake_max_retry_count = 100" ); err != nil {
415+ log .Printf ("Warning: failed to set ducklake_max_retry_count: %v" , err )
416+ // Don't fail - this is not critical, DuckLake will use its default
417+ }
418+
409419 return nil
410420}
411421
You can’t perform that action at this time.
0 commit comments