MULTI_THREADED );
}
else
{
LOGGER.info( "Creating {} for pipeline tuple queue of regionId={} replicaIndex={} as first operator is {}",
<BUG>EmptyOperatorTupleQueue.class.getSimpleName(),

regionId, replicaIndex,</BUG>
firstOperatorDef.operatorType() );
pipelineTupleQueue = new EmptyOperatorTupleQueue( firstOperatorDef.id(), firstOperatorDef.inputPortCount() );

MULTI_THREADED );
}
else
{
LOGGER.info( "Creating {} for pipeline tuple queue of regionId={} replicaIndex={} as first operator is {}",
EmptyOperatorTupleQueue.class.getSimpleName(), regionId, replicaIndex,
firstOperatorDef.operatorType() );
pipelineTupleQueue = new EmptyOperatorTupleQueue( firstOperatorDef.id(), firstOperatorDef.inputPortCount() );
