Repository: spark Updated Branches: refs/heads/master 2a53fbfce -> a4eac8b0b
[MINOR] Remove **** in test case names in FlatMapGroupsWithStateSuite ## What changes were proposed in this pull request? This patch removes the `****` string from test names in FlatMapGroupsWithStateSuite. `***` is a common string developers grep for when using Scala test (because it immediately shows the failing test cases). The existence of the `****` in test names disrupts that workflow. ## How was this patch tested? N/A - test only change. Author: Reynold Xin <[email protected]> Closes #18715 from rxin/FlatMapGroupsWithStateStar. Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/a4eac8b0 Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/a4eac8b0 Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/a4eac8b0 Branch: refs/heads/master Commit: a4eac8b0bb2a00a898bc216376fe770aa402c893 Parents: 2a53fbf Author: Reynold Xin <[email protected]> Authored: Sun Jul 23 10:41:38 2017 -0700 Committer: gatorsmile <[email protected]> Committed: Sun Jul 23 10:41:38 2017 -0700 ---------------------------------------------------------------------- .../spark/sql/streaming/FlatMapGroupsWithStateSuite.scala | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/a4eac8b0/sql/core/src/test/scala/org/apache/spark/sql/streaming/FlatMapGroupsWithStateSuite.scala ---------------------------------------------------------------------- diff --git a/sql/core/src/test/scala/org/apache/spark/sql/streaming/FlatMapGroupsWithStateSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/streaming/FlatMapGroupsWithStateSuite.scala index a5399cd..9d74a5c 100644 --- a/sql/core/src/test/scala/org/apache/spark/sql/streaming/FlatMapGroupsWithStateSuite.scala +++ b/sql/core/src/test/scala/org/apache/spark/sql/streaming/FlatMapGroupsWithStateSuite.scala @@ -99,7 +99,7 @@ class FlatMapGroupsWithStateSuite extends StateStoreMetricsTest with BeforeAndAf } } - test("GroupState - setTimeout**** with NoTimeout") { + test("GroupState - setTimeout - with NoTimeout") { for (initValue <- Seq(None, Some(5))) { val states = Seq( GroupStateImpl.createForStreaming(initValue, 1000, 1000, NoTimeout, hasTimedOut = false), @@ -117,7 +117,7 @@ class FlatMapGroupsWithStateSuite extends StateStoreMetricsTest with BeforeAndAf } } - test("GroupState - setTimeout**** with ProcessingTimeTimeout") { + test("GroupState - setTimeout - with ProcessingTimeTimeout") { // for streaming queries var state: GroupStateImpl[Int] = GroupStateImpl.createForStreaming( None, 1000, 1000, ProcessingTimeTimeout, hasTimedOut = false) @@ -156,7 +156,7 @@ class FlatMapGroupsWithStateSuite extends StateStoreMetricsTest with BeforeAndAf testTimeoutTimestampNotAllowed[UnsupportedOperationException](state) } - test("GroupState - setTimeout**** with EventTimeTimeout") { + test("GroupState - setTimeout - with EventTimeTimeout") { var state: GroupStateImpl[Int] = GroupStateImpl.createForStreaming( None, 1000, 1000, EventTimeTimeout, false) @@ -195,7 +195,7 @@ class FlatMapGroupsWithStateSuite extends StateStoreMetricsTest with BeforeAndAf testTimeoutDurationNotAllowed[UnsupportedOperationException](state) } - test("GroupState - illegal params to setTimeout****") { + test("GroupState - illegal params to setTimeout") { var state: GroupStateImpl[Int] = null // Test setTimeout****() with illegal values --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
