You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2015/06/04 13:28:22 UTC
[4/4] flink git commit: [FLINK-2126] [scala shell] All tests now dont
check for "Job execution switched to status FINISHED.",
which sometimes did not show up. Fixed typo in add numbers test
[FLINK-2126] [scala shell] All tests now dont check for "Job execution switched to status FINISHED.", which sometimes did not show up.
Fixed typo in add numbers test
This closes #768
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5e09e9bb
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5e09e9bb
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/5e09e9bb
Branch: refs/heads/master
Commit: 5e09e9bbf5c3a8b2554271eea56ee5081da3dc90
Parents: 0081fb2
Author: Nikolaas Steenbergen <Ni...@googlemail.com>
Authored: Wed Jun 3 12:39:02 2015 +0200
Committer: Stephan Ewen <se...@apache.org>
Committed: Thu Jun 4 13:27:22 2015 +0200
----------------------------------------------------------------------
.../scala/org/apache/flink/api/scala/ScalaShellITSuite.scala | 8 +-------
1 file changed, 1 insertion(+), 7 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/5e09e9bb/flink-staging/flink-scala-shell/src/test/scala/org/apache/flink/api/scala/ScalaShellITSuite.scala
----------------------------------------------------------------------
diff --git a/flink-staging/flink-scala-shell/src/test/scala/org/apache/flink/api/scala/ScalaShellITSuite.scala b/flink-staging/flink-scala-shell/src/test/scala/org/apache/flink/api/scala/ScalaShellITSuite.scala
index 412592f..c3bb320 100644
--- a/flink-staging/flink-scala-shell/src/test/scala/org/apache/flink/api/scala/ScalaShellITSuite.scala
+++ b/flink-staging/flink-scala-shell/src/test/scala/org/apache/flink/api/scala/ScalaShellITSuite.scala
@@ -55,8 +55,6 @@ class ScalaShellITSuite extends FunSuite with Matchers with BeforeAndAfterAll {
output should not include "failed"
output should not include "error"
output should not include "Exception"
-
- output should include("Job execution switched to status FINISHED.")
}
test("WordCount in Shell") {
@@ -85,7 +83,7 @@ class ScalaShellITSuite extends FunSuite with Matchers with BeforeAndAfterAll {
output should include("(arrows,1)")
}
- test("Sum 1..0, should be 55") {
+ test("Sum 1..10, should be 55") {
val input : String =
"""
val input: DataSet[Int] = env.fromElements(0,1,2,3,4,5,6,7,8,9,10)
@@ -99,8 +97,6 @@ class ScalaShellITSuite extends FunSuite with Matchers with BeforeAndAfterAll {
output should not include "error"
output should not include "Exception"
- output should include("Job execution switched to status FINISHED.")
-
output should include("55")
}
@@ -125,8 +121,6 @@ class ScalaShellITSuite extends FunSuite with Matchers with BeforeAndAfterAll {
output should not include "error"
output should not include "Exception"
- output should include("Job execution switched to status FINISHED.")
-
output should include("WC(hello,1)")
output should include("WC(world,10)")
}