[FLINK-4592] [table] Fix flaky test ScalarFunctionsTest.testCurrentTi…

…mePoint
chenjw · Sep 9, 2016 · 8c0d624 · 8c0d624
1 parent e92f91a
commit 8c0d624
Showing 1 changed file with 18 additions and 18 deletions.
diff --git a/...ink-table/src/test/scala/org/apache/flink/api/table/expressions/ScalarFunctionsTest.scala b/...ink-table/src/test/scala/org/apache/flink/api/table/expressions/ScalarFunctionsTest.scala
@@ -791,34 +791,34 @@ class ScalarFunctionsTest extends ExpressionTestBase {
     // manual test can be found in NonDeterministicTests
 
     testAllApis(
-      currentDate().cast(Types.STRING).charLength(),
-      "currentDate().cast(STRING).charLength()",
-      "CHAR_LENGTH(CAST(CURRENT_DATE AS VARCHAR))",
-      "10")
+      currentDate().cast(Types.STRING).charLength() >= 5,
+      "currentDate().cast(STRING).charLength() >= 5",
+      "CHAR_LENGTH(CAST(CURRENT_DATE AS VARCHAR)) >= 5",
+      "true")
 
     testAllApis(
-      currentTime().cast(Types.STRING).charLength(),
-      "currentTime().cast(STRING).charLength()",
-      "CHAR_LENGTH(CAST(CURRENT_TIME AS VARCHAR))",
-      "8")
+      currentTime().cast(Types.STRING).charLength() >= 5,
+      "currentTime().cast(STRING).charLength() >= 5",
+      "CHAR_LENGTH(CAST(CURRENT_TIME AS VARCHAR)) >= 5",
+      "true")
 
     testAllApis(
-      currentTimestamp().cast(Types.STRING).charLength() >= 22,
-      "currentTimestamp().cast(STRING).charLength() >= 22",
-      "CHAR_LENGTH(CAST(CURRENT_TIMESTAMP AS VARCHAR)) >= 22",
+      currentTimestamp().cast(Types.STRING).charLength() >= 12,
+      "currentTimestamp().cast(STRING).charLength() >= 12",
+      "CHAR_LENGTH(CAST(CURRENT_TIMESTAMP AS VARCHAR)) >= 12",
       "true")
 
     testAllApis(
-      localTimestamp().cast(Types.STRING).charLength() >= 22,
-      "localTimestamp().cast(STRING).charLength() >= 22",
-      "CHAR_LENGTH(CAST(LOCALTIMESTAMP AS VARCHAR)) >= 22",
+      localTimestamp().cast(Types.STRING).charLength() >= 12,
+      "localTimestamp().cast(STRING).charLength() >= 12",
+      "CHAR_LENGTH(CAST(LOCALTIMESTAMP AS VARCHAR)) >= 12",
       "true")
 
     testAllApis(
-      localTime().cast(Types.STRING).charLength(),
-      "localTime().cast(STRING).charLength()",
-      "CHAR_LENGTH(CAST(LOCALTIME AS VARCHAR))",
-      "8")
+      localTime().cast(Types.STRING).charLength() >= 5,
+      "localTime().cast(STRING).charLength() >= 5",
+      "CHAR_LENGTH(CAST(LOCALTIME AS VARCHAR)) >= 5",
+      "true")
 
     // comparisons are deterministic
     testAllApis(