[flink] 02/04: [FLINK-13463][table-planner-blink] Add test case for VALUES with char literal

[twalthr]

This is an automated email from the ASF dual-hosted git repository.

twalthr pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 63e9a167fba59be2addaedc74e5d235ec6739832
Author: Timo Walther <twal...@apache.org>
AuthorDate: Wed Jul 31 17:36:38 2019 +0200

    [FLINK-13463][table-planner-blink] Add test case for VALUES with char 
literal
---
 .../table/planner/runtime/stream/sql/ValuesITCase.scala      | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git 
a/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/ValuesITCase.scala
 
b/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/ValuesITCase.scala
index e43c6d2..4a9fd45 100644
--- 
a/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/ValuesITCase.scala
+++ 
b/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/ValuesITCase.scala
@@ -23,8 +23,7 @@ import org.apache.flink.table.api.scala._
 import org.apache.flink.table.dataformat.BaseRow
 import org.apache.flink.table.planner.runtime.utils.{StreamingTestBase, 
TestingAppendBaseRowSink}
 import org.apache.flink.table.runtime.typeutils.BaseRowTypeInfo
-import org.apache.flink.table.types.logical.IntType
-
+import org.apache.flink.table.types.logical.{IntType, VarCharType}
 import org.junit.Assert._
 import org.junit.Test
 
@@ -33,17 +32,18 @@ class ValuesITCase extends StreamingTestBase {
   @Test
   def testValues(): Unit = {
 
-    val sqlQuery = "SELECT * FROM (VALUES (1, 2, 3)) T(a, b, c)"
+    val sqlQuery = "SELECT * FROM (VALUES (1, 'Bob'), (1, 'Alice')) T(a, b)"
 
-    val outputType = new BaseRowTypeInfo(new IntType(), new IntType(), new 
IntType())
+    val outputType = new BaseRowTypeInfo(
+      new IntType(),
+      new VarCharType(5))
 
     val result = tEnv.sqlQuery(sqlQuery).toAppendStream[BaseRow]
     val sink = new TestingAppendBaseRowSink(outputType)
     result.addSink(sink).setParallelism(1)
     env.execute()
 
-    val expected = List("0|1,2,3")
+    val expected = List("0|1,Alice", "0|1,Bob")
     assertEquals(expected.sorted, sink.getAppendResults.sorted)
   }
-
 }