From 8bcad28a5a6788c96bf1c302eb6f18d37b798b03 Mon Sep 17 00:00:00 2001
From: proflin <proflin.me@gmail.com>
Date: Wed, 9 Mar 2016 21:12:27 -0800
Subject: [PATCH] =?UTF-8?q?[SPARK-7420][STREAMING][TESTS]=20Enable=20test:?=
=?UTF-8?q?=20o.a.s.streaming.JobGeneratorSuite=20"Do=20not=20clear=20rece?=
=?UTF-8?q?ived=E2=80=A6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
## How was this patch tested?
unit test
Author: proflin <proflin.me@gmail.com>
Closes #11626 from lw-lin/SPARK-7420.
---
.../apache/spark/streaming/scheduler/JobGeneratorSuite.scala | 3 +--
1 file changed, 1 insertion(+), 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
--
GitLab