hubcio opened a new pull request, #2743: URL: https://github.com/apache/iggy/pull/2743
Source handler tasks were fire-and-forget (JoinHandle dropped), so the tokio runtime could cancel them mid-state-save during shutdown. FileStateProvider::save() uses a non-atomic truncate then write sequence — cancellation between the two left the state file empty. On restart the connector loaded no tracking offsets and re-polled all rows from the source database. Retain handler JoinHandles and await them (with timeout) after dropping flume senders but before shutting down Iggy clients. Also add sync_all() after write_all() in save() to ensure data reaches disk before returning. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
