diff --git a/flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java b/flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java index 68dc7bd3f813a0..728b5de6d68506 100644 --- a/flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java +++ b/flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java @@ -158,7 +158,8 @@ ANY, and(logical(LogicalTypeRoot.BOOLEAN), LITERAL) sequence( Arrays.asList("haystack", "needle"), Arrays.asList( - logical(LogicalTypeRoot.ARRAY), FIRST_ARRAY_ELEMENT_ARG))) + logical(LogicalTypeRoot.ARRAY), + FIRST_ARRAY_ELEMENT_ARG))) .outputTypeStrategy( nullableIfArgs( ConstantArgumentCount.of(0), explicit(DataTypes.BOOLEAN()))) @@ -174,7 +175,8 @@ ANY, and(logical(LogicalTypeRoot.BOOLEAN), LITERAL) sequence( Arrays.asList("haystack", "element"), Arrays.asList( - logical(LogicalTypeRoot.ARRAY), FIRST_ARRAY_ELEMENT_ARG))) + logical(LogicalTypeRoot.ARRAY), + FIRST_ARRAY_ELEMENT_ARG))) .outputTypeStrategy(nullableIfArgs(argument(0))) .runtimeClass( "org.apache.flink.table.runtime.functions.scalar.ArrayAppendFunction") 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 5c4f1f2f316e1f..40ff8254548184 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 @@ -35,11 +35,12 @@ class CollectionFunctionsITCase extends BuiltInFunctionTestBase { Stream getTestSetSpecs() { return Stream.of( TestSetSpec.forFunction(BuiltInFunctionDefinitions.ARRAY_APPEND) - .testResult( + .testResult( $("f2").arrayPrepend("!"), "ARRAY_PREPEND('!', f2)", new String[] {"!", "Hello", "World"}, - DataTypes.ARRAY(DataTypes.STRING())) .onFieldsWithData( + DataTypes.ARRAY(DataTypes.STRING())) + .onFieldsWithData( new Integer[] {1, 2}, null, new String[] {"Hello", "World"}) .andDataTypes( DataTypes.ARRAY(DataTypes.INT()),