Repository: spark Updated Branches: refs/heads/master 8a3acb792 -> 8bcad28a5
[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...@gmail.com> Closes #11626 from lw-lin/SPARK-7420. Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/8bcad28a Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/8bcad28a Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/8bcad28a Branch: refs/heads/master Commit: 8bcad28a5a6788c96bf1c302eb6f18d37b798b03 Parents: 8a3acb7 Author: proflin <proflin...@gmail.com> Authored: Wed Mar 9 21:12:27 2016 -0800 Committer: Reynold Xin <r...@databricks.com> Committed: Wed Mar 9 21:12:27 2016 -0800 ---------------------------------------------------------------------- .../org/apache/spark/streaming/scheduler/JobGeneratorSuite.scala | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/8bcad28a/streaming/src/test/scala/org/apache/spark/streaming/scheduler/JobGeneratorSuite.scala ---------------------------------------------------------------------- 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 9b6cd4b..a2dbae1 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 --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org For additional commands, e-mail: commits-h...@spark.apache.org
