This is an automated email from the ASF dual-hosted git repository. twalthr pushed a commit to branch release-1.9 in repository https://gitbox.apache.org/repos/asf/flink.git
commit 2f4e5eab3ee983f76952a4867403eced7bdd32de 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) } - }