operatorDef,
threadingPreference );
}
final TupleQueueDrainerPool drainerPool = createTupleQueueDrainer( operatorDef, isFirstOperator );
LOGGER.info( "Creating {} for regionId={} replicaIndex={} operatorId={}",
<BUG>drainerPool.getClass().getSimpleName(), regionId, replicaIndex,
operatorId );</BUG>
final OperatorKVStore operatorKVStore;
if ( operatorDef.operatorType() == STATELESS )
{

operatorDef,
threadingPreference );
}
final TupleQueueDrainerPool drainerPool = createTupleQueueDrainer( operatorDef, isFirstOperator );
LOGGER.info( "Creating {} for regionId={} replicaIndex={} operatorId={}",
drainerPool.getClass().getSimpleName(),
regionId,
replicaIndex,
operatorId );
final OperatorKVStore operatorKVStore;
if ( operatorDef.operatorType() == STATELESS )
{
