@KuduClusterTestContext(kuduClusterBasedTest = true)
@Test
public void testNumberOfPartitions() throws Exception
{

  numberOfKuduInputOperatorPartitions = -1; // situation when the user has not set the partitions explicitly
  initOperatorState();
  AbstractKuduInputPartitioner partitioner = unitTestStepwiseScanInputOperator.getPartitioner();
  assertEquals(1,partitioner.getNumberOfPartitions(partitioningContext));
  numberOfKuduInputOperatorPartitions = 7; // situation when the user has not set the partitions explicitly
  initOperatorState();
  partitioner = unitTestStepwiseScanInputOperator.getPartitioner();
  assertEquals(7,partitioner.getNumberOfPartitions(partitioningContext));
  numberOfKuduInputOperatorPartitions = -1; // revert the value back to default
}