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

Reply via email to