Fix bug in unit test

scwf · Jan 22, 2015 · e356258 · e356258
1 parent 558bdc3
commit e356258
Showing 1 changed file with 0 additions and 5 deletions.
diff --git a/streaming/src/test/scala/org/apache/spark/streaming/ReceivedBlockTrackerSuite.scala b/streaming/src/test/scala/org/apache/spark/streaming/ReceivedBlockTrackerSuite.scala
@@ -82,11 +82,6 @@ class ReceivedBlockTrackerSuite
     receivedBlockTracker.allocateBlocksToBatch(2)
     receivedBlockTracker.getBlocksOfBatchAndStream(2, streamId) shouldBe empty
 
-    // Verify that batch 2 cannot be allocated again
-    intercept[SparkException] {
-      receivedBlockTracker.allocateBlocksToBatch(2)
-    }
-
     // Verify that older batches cannot be allocated again
     intercept[SparkException] {
       receivedBlockTracker.allocateBlocksToBatch(1)