diff options
| author | proflin <proflin.me@gmail.com> | 2016-03-09 21:12:27 -0800 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2016-03-09 21:12:27 -0800 |
| commit | 8bcad28a5a6788c96bf1c302eb6f18d37b798b03 (patch) | |
| tree | 027cac07b34b50433e66dc64d15b58681c010324 /streaming | |
| parent | 8a3acb792d3a816dd0017fb4b79fc05152472b83 (diff) | |
| download | spark-8bcad28a5a6788c96bf1c302eb6f18d37b798b03.tar.gz spark-8bcad28a5a6788c96bf1c302eb6f18d37b798b03.tar.bz2 spark-8bcad28a5a6788c96bf1c302eb6f18d37b798b03.zip | |
[SPARK-7420][STREAMING][TESTS] Enable test: o.a.s.streaming.JobGeneratorSuite "Do not clear received…
## How was this patch tested?
unit test
Author: proflin <proflin.me@gmail.com>
Closes #11626 from lw-lin/SPARK-7420.
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/src/test/scala/org/apache/spark/streaming/scheduler/JobGeneratorSuite.scala | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/streaming/src/test/scala/org/apache/spark/streaming/scheduler/JobGeneratorSuite.scala b/streaming/src/test/scala/org/apache/spark/streaming/scheduler/JobGeneratorSuite.scala index 9b6cd4bc4e..a2dbae149f 100644 --- a/streaming/src/test/scala/org/apache/spark/streaming/scheduler/JobGeneratorSuite.scala +++ b/streaming/src/test/scala/org/apache/spark/streaming/scheduler/JobGeneratorSuite.scala @@ -56,8 +56,7 @@ class JobGeneratorSuite extends TestSuiteBase { // 4. allow subsequent batches to be generated (to allow premature deletion of 3rd batch metadata) // 5. verify whether 3rd batch's block metadata still exists // - // TODO: SPARK-7420 enable this test - ignore("SPARK-6222: Do not clear received block data too soon") { + test("SPARK-6222: Do not clear received block data too soon") { import JobGeneratorSuite._ val checkpointDir = Utils.createTempDir() val testConf = conf |