Skip to content

Commit 174b4db

Browse files
committed
Added array test in PostgresCatalogITCase#testArrayTypes()
1 parent a9bfe78 commit 174b4db

File tree

2 files changed

+4
-0
lines changed

2 files changed

+4
-0
lines changed

flink-connectors/flink-jdbc/src/test/java/org/apache/flink/api/java/io/jdbc/catalog/PostgresCatalogITCase.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -103,6 +103,7 @@ public void testArrayTypes() throws Exception {
103103
"[5.5, 6.6, 7.7]," +
104104
"[6.6, 7.7, 8.8]," +
105105
"[7.70000, 8.80000, 9.90000]," +
106+
"[8.800000000000000000, 9.900000000000000000, 10.100000000000000000]," +
106107
"[true, false, true]," +
107108
"[a, b, c]," +
108109
"[b, c, d]," +

flink-connectors/flink-jdbc/src/test/java/org/apache/flink/api/java/io/jdbc/catalog/PostgresCatalogTestBase.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -225,6 +225,7 @@ public static TestTable getArrayTable() {
225225
.field("real_arr", DataTypes.ARRAY(DataTypes.FLOAT()))
226226
.field("double_precision_arr", DataTypes.ARRAY(DataTypes.DOUBLE()))
227227
.field("numeric_arr", DataTypes.ARRAY(DataTypes.DECIMAL(10, 5)))
228+
.field("numeric_arr_default", DataTypes.ARRAY(DataTypes.DECIMAL(DecimalType.MAX_PRECISION, 18)))
228229
.field("boolean_arr", DataTypes.ARRAY(DataTypes.BOOLEAN()))
229230
.field("text_arr", DataTypes.ARRAY(DataTypes.STRING()))
230231
.field("char_arr", DataTypes.ARRAY(DataTypes.CHAR(1)))
@@ -243,6 +244,7 @@ public static TestTable getArrayTable() {
243244
"real_arr real[], " +
244245
"double_precision_arr double precision[], " +
245246
"numeric_arr numeric(10, 5)[], " +
247+
"numeric_arr_default numeric[], " +
246248
"boolean_arr boolean[], " +
247249
"text_arr text[], " +
248250
"char_arr char[], " +
@@ -260,6 +262,7 @@ public static TestTable getArrayTable() {
260262
"'{5.5,6.6,7.7}'," +
261263
"'{6.6,7.7,8.8}'," +
262264
"'{7.7,8.8,9.9}'," +
265+
"'{8.8,9.9,10.10}'," +
263266
"'{true,false,true}'," +
264267
"'{a,b,c}'," +
265268
"'{b,c,d}'," +

0 commit comments

Comments
 (0)