HeartSaVioR opened a new pull request, #38911: URL: https://github.com/apache/spark/pull/38911
### What changes were proposed in this pull request? This PR proposes to add defensive assertions to Kafka data source for Trigger.AvailableNow, so that the query will rather fail fast instead of infinite run if there will be a bug in Kafka data source. ### Why are the changes needed? This change will play as a safeguard that the future bug in Kafka data source won't lead to infinite query run. ### Does this PR introduce _any_ user-facing change? No. ### How was this patch tested? Existing tests. -- 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: reviews-unsubscr...@spark.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org --------------------------------------------------------------------- To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For additional commands, e-mail: reviews-h...@spark.apache.org
