final boolean isFirstOperator = ( operatorIndex == 0 ), isLastOperator = ( operatorIndex == ( operatorCount - 1 ) );
final OperatorTupleQueue operatorTupleQueue;
if ( flow.getUpstreamConnections( operatorId ).isEmpty() )
{
LOGGER.info( "Creating {} for regionId={} replicaIndex={} operatorId={}",
<BUG>EmptyOperatorTupleQueue.class.getSimpleName(), regionId, replicaIndex,
operatorId );</BUG>
operatorTupleQueue = new EmptyOperatorTupleQueue( operatorId, operatorDef.inputPortCount() );
}
else if ( operatorDef.operatorType() == PARTITIONED_STATEFUL )

final boolean isFirstOperator = ( operatorIndex == 0 ), isLastOperator = ( operatorIndex == ( operatorCount - 1 ) );
final OperatorTupleQueue operatorTupleQueue;
if ( flow.getUpstreamConnections( operatorId ).isEmpty() )
{
LOGGER.info( "Creating {} for regionId={} replicaIndex={} operatorId={}",
EmptyOperatorTupleQueue.class.getSimpleName(),
regionId,
replicaIndex,
operatorId );
operatorTupleQueue = new EmptyOperatorTupleQueue( operatorId, operatorDef.inputPortCount() );
}
else if ( operatorDef.operatorType() == PARTITIONED_STATEFUL )
