private CompletionStage < Void > prepareOnOtherNode ( Node node ) { LOG . trace ( "[{}] Repreparing on {}" , logPrefix , node ) ; DriverChannel channel = session . getChannel ( node , logPrefix ) ; if ( channel == null ) { LOG . trace ( "[{}] Could not get a channel to reprepare on {}, skipping" , logPrefix , node ) ; return CompletableFuture . completedFuture ( null ) ; } else { ThrottledAdminRequestHandler handler = new ThrottledAdminRequestHandler ( channel , message , request . getCustomPayload ( ) , timeout , throttler , session . getMetricUpdater ( ) , logPrefix , message . toString ( ) ) ; return handler . start ( ) . handle ( ( result , error ) -> { if ( error == null ) { LOG . trace ( "[{}] Successfully reprepared on {}" , logPrefix , node ) ; } else { Loggers . warnWithException ( LOG , "[{}] Error while repreparing on {}" , node , logPrefix , error ) ; } return null ; } ) ; } }
blocking the preparation will be retried later on that node . Simply warn and move on .