You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by li...@apache.org on 2017/07/23 17:41:42 UTC
spark git commit: [MINOR] Remove **** in test case names in
FlatMapGroupsWithStateSuite
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 <rx...@databricks.com>
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 <rx...@databricks.com>
Authored: Sun Jul 23 10:41:38 2017 -0700
Committer: gatorsmile <ga...@gmail.com>
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: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org