npawar opened a new issue #4627: Exception in creating stream consumer puts segments into ERROR state URL: https://github.com/apache/incubator-pinot/issues/4627 We recently encountered a situation: 1) When starting a new consuming segment, we try to create the stream consumer. This is in LLRealtimeSegmentDataManager constructor, the call to makeStreamConsumer 2) If we encounter an exception in makeStreamConsumer, the entire state transition fails 3) The segment goes into ERROR state. Only ways to recover: 1) Restart We should be able to gracefully recover from this. Some solutions: 1) Catch this as a transient exception, and call handleTransientException. This method will retry creating streamConsumer after a 1s sleep. The retry will happen 5 times.
---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
