Unignored tests for EpochCoordinator sequencing of late epochs

Efim Poberezkin · Efim Poberezkin · commit 478291b26ecc · 2018-04-18T13:55:34.000+04:00
diff --git a/sql/core/src/test/scala/org/apache/spark/sql/streaming/continuous/EpochCoordinatorSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/streaming/continuous/EpochCoordinatorSuite.scala
@@ -120,7 +120,7 @@ class EpochCoordinatorSuite
     verifyCommitsInOrderOf(List(1, 2))
   }
 
-  ignore("consequent epochs, a message for epoch k arrives after messages for epoch (k + 1)") {
+  test("consequent epochs, a message for epoch k arrives after messages for epoch (k + 1)") {
     setWriterPartitions(2)
     setReaderPartitions(2)
 
@@ -141,7 +141,7 @@ class EpochCoordinatorSuite
     verifyCommitsInOrderOf(List(1, 2))
   }
 
-  ignore("several epochs, messages arrive in order 1 -> 3 -> 4 -> 2") {
+  test("several epochs, messages arrive in order 1 -> 3 -> 4 -> 2") {
     setWriterPartitions(1)
     setReaderPartitions(1)
 
@@ -162,7 +162,7 @@ class EpochCoordinatorSuite
     verifyCommitsInOrderOf(List(1, 2, 3, 4))
   }
 
-  ignore("several epochs, messages arrive in order 1 -> 3 -> 5 -> 4 -> 2") {
+  test("several epochs, messages arrive in order 1 -> 3 -> 5 -> 4 -> 2") {
     setWriterPartitions(1)
     setReaderPartitions(1)
 

Original file line number	Diff line number	Diff line change
`@@ -120,7 +120,7 @@ class EpochCoordinatorSuite`
`120`	`120`	`verifyCommitsInOrderOf(List(1, 2))`
`121`	`121`	`}`
`122`	`122`
`123`		`- ignore("consequent epochs, a message for epoch k arrives after messages for epoch (k + 1)") {`
	`123`	`+ test("consequent epochs, a message for epoch k arrives after messages for epoch (k + 1)") {`
`124`	`124`	`setWriterPartitions(2)`
`125`	`125`	`setReaderPartitions(2)`
`126`	`126`
`@@ -141,7 +141,7 @@ class EpochCoordinatorSuite`
`141`	`141`	`verifyCommitsInOrderOf(List(1, 2))`
`142`	`142`	`}`
`143`	`143`
`144`		`- ignore("several epochs, messages arrive in order 1 -> 3 -> 4 -> 2") {`
	`144`	`+ test("several epochs, messages arrive in order 1 -> 3 -> 4 -> 2") {`
`145`	`145`	`setWriterPartitions(1)`
`146`	`146`	`setReaderPartitions(1)`
`147`	`147`
`@@ -162,7 +162,7 @@ class EpochCoordinatorSuite`
`162`	`162`	`verifyCommitsInOrderOf(List(1, 2, 3, 4))`
`163`	`163`	`}`
`164`	`164`
`165`		`- ignore("several epochs, messages arrive in order 1 -> 3 -> 5 -> 4 -> 2") {`
	`165`	`+ test("several epochs, messages arrive in order 1 -> 3 -> 5 -> 4 -> 2") {`
`166`	`166`	`setWriterPartitions(1)`
`167`	`167`	`setReaderPartitions(1)`
`168`	`168`