diff --git a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/CollectionFunctionsITCase.java b/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/CollectionFunctionsITCase.java index 42fd74a7747288..2b98a5e642d91f 100644 --- a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/CollectionFunctionsITCase.java +++ b/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/CollectionFunctionsITCase.java @@ -239,8 +239,8 @@ Stream getTestSetSpecs() { TestSetSpec.forFunction(BuiltInFunctionDefinitions.MAP_FROM_ARRAYS, "Invalid input") .onFieldsWithData(null, null, new Integer[] {1}, new Integer[] {1, 2}) .andDataTypes( - DataTypes.BOOLEAN().nullable(), - DataTypes.INT().nullable(), + DataTypes.ARRAY(DataTypes.BOOLEAN()), + DataTypes.ARRAY(DataTypes.STRING()), DataTypes.ARRAY(DataTypes.INT()), DataTypes.ARRAY(DataTypes.INT())) .testTableApiRuntimeError( @@ -250,7 +250,12 @@ Stream getTestSetSpecs() { .testSqlRuntimeError( "MAP_FROM_ARRAYS(array[1, 2, 3], array[1, 2])", "Invalid function MAP_FROM_ARRAYS call:\n" - + "The length of the keys array 3 is not equal to the length of the values array 2"), + + "The length of the keys array 3 is not equal to the length of the values array 2") + .testResult( + mapFromArrays($("f0"), $("f1")), + "MAP_FROM_ARRAYS(f0, f1)", + null, + DataTypes.MAP(DataTypes.BOOLEAN(), DataTypes.STRING())), TestSetSpec.forFunction(BuiltInFunctionDefinitions.MAP_FROM_ARRAYS) .onFieldsWithData( new Integer[] {1, 2},