assertEquals(hiveSplitSource.getNextBatch(1).size(), 1);
assertEquals(hiveSplitSource.getOutstandingSplitCount(), 9);
assertFalse(suspendingExecutor.isSuspended());
// add two more splits so the source is now full and verify that the executor is suspended
hiveSplitSource.addToQueue(new TestSplit(11));
hiveSplitSource.addToQueue(new TestSplit(12));
assertEquals(hiveSplitSource.getOutstandingSplitCount(), 11);
assertTrue(suspendingExecutor.isSuspended());
// remove two splits so the source is no longer full and verify the executor is resumed