You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by dw...@apache.org on 2020/07/16 08:14:23 UTC
[flink] 02/02: [FLINK-18608] Add test for nullability overwriting
in VALUES
This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a commit to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 71fa2c1402497013c8c1d24093edaf6962e5c66a
Author: Dawid Wysakowicz <dw...@apache.org>
AuthorDate: Wed Jul 15 17:49:13 2020 +0200
[FLINK-18608] Add test for nullability overwriting in VALUES
---
.../planner/runtime/stream/table/ValuesITCase.java | 17 +++++++++++++++++
1 file changed, 17 insertions(+)
diff --git a/flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/runtime/stream/table/ValuesITCase.java b/flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/runtime/stream/table/ValuesITCase.java
index 0912363..f86235f 100644
--- a/flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/runtime/stream/table/ValuesITCase.java
+++ b/flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/runtime/stream/table/ValuesITCase.java
@@ -335,6 +335,23 @@ public class ValuesITCase extends StreamingTestBase {
assertThat(results, equalTo(Collections.singletonList(row)));
}
+ @Test
+ public void testNullabilityOverwriting() {
+ Row row = Row.of(1, "ABC");
+ Table values = tEnv().fromValues(
+ DataTypes.ROW(
+ DataTypes.FIELD("f0", DataTypes.INT().nullable()),
+ DataTypes.FIELD("f1", DataTypes.STRING().nullable())
+ ),
+ Collections.singletonList(row));
+ tEnv().createTemporaryView("values_t", values);
+ Iterator<Row> iter = tEnv().executeSql("select * from values_t").collect();
+
+ List<Row> results = new ArrayList<>();
+ iter.forEachRemaining(results::add);
+ assertThat(results, equalTo(Collections.singletonList(row)));
+ }
+
/**
* A {@link ScalarFunction} that takes all supported types as parameters and
* converts them to String.