private synchronized void cleanupState(){
  sourceIds=null;
  targets=null;
  if (executor != null) {
    executor.shutdown();
    executor=null;
  }
}

private synchronized void cleanupState ( ) { sourceIds = null ; targets = null ; if ( executor != null ) { executor . shutdown ( ) ; executor = null ; } }
remove any state from memory that should not be kept past the completion of the reconciliation run
