operatorTupleQueue = new EmptyOperatorTupleQueue( operatorId, operatorDef.inputPortCount() );
}
else if ( operatorDef.operatorType() == PARTITIONED_STATEFUL )
{
LOGGER.info( "Creating {} for regionId={} replicaIndex={} operatorId={}",
<BUG>PartitionedOperatorTupleQueue.class.getSimpleName(), regionId, replicaIndex,
operatorId );</BUG>
final OperatorTupleQueue[] operatorTupleQueues = operatorTupleQueueManager.getPartitionedOperatorTupleQueuesOrFail(
regionId,
operatorDef.id() );

operatorTupleQueue = new EmptyOperatorTupleQueue( operatorId, operatorDef.inputPortCount() );
}
else if ( operatorDef.operatorType() == PARTITIONED_STATEFUL )
{
LOGGER.info( "Creating {} for regionId={} replicaIndex={} operatorId={}",
PartitionedOperatorTupleQueue.class.getSimpleName(),
regionId,
replicaIndex,
operatorId );
final OperatorTupleQueue[] operatorTupleQueues = operatorTupleQueueManager.getPartitionedOperatorTupleQueuesOrFail(
regionId,
operatorDef.id() );
