question: private void startClient ( ) { if ( flumeClient != null && ! flumeClient . isActive ( ) ) { flumeClient . close ( ) ; flumeClient = null ; } if ( flumeClient == null ) { try { flumeClient = RpcClientFactory . getDefaultInstance ( flumeHostName , flumePort , maxSpanBatchSize ) ; } catch ( FlumeException e ) { LOG . warn ( "Failed to create Flume RPC Client. " + e . getMessage ( ) ) ; } } }
target:  Create / reconnect Flume RPC client