private void quiesceIngestWithReprocess ( ) throws IOException { if ( ingest != null ) { LOG . info ( "Standby: Quiescing - quiescing ongoing ingest" ) ; quiesceIngest ( ) ; reprocessCurrentSegmentIfNeeded ( ingest . getIngestStatus ( ) ) ; } }
When ingest consumes the end of segment transaction it sets the state to not ingesting . This function ensures that the ingest thread exited .