@Test
public void testParallelPartitionScaleUP()
{

  DummyOperator dummyOperator = new DummyOperator(5);
  StatelessPartitioner<DummyOperator> statelessPartitioner = new StatelessPartitioner<>();
  Collection<Partition<DummyOperator>> partitions = Lists.newArrayList();
  partitions.add(new DefaultPartition<>(dummyOperator));
  Collection<Partition<DummyOperator>> newPartitions = statelessPartitioner.definePartitions(partitions,
      new PartitioningContextImpl(null, 5));
  Assert.assertEquals("after partition", 5, newPartitions.size());
}