diff --git a/flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/RootArgumentTypeStrategy.java b/flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/RootArgumentTypeStrategy.java index 26799805aa11b..3658d1fbdb43f 100644 --- a/flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/RootArgumentTypeStrategy.java +++ b/flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/RootArgumentTypeStrategy.java @@ -61,7 +61,7 @@ public Optional inferArgumentType( if (Objects.equals(expectedNullability, Boolean.FALSE) && actualType.isNullable()) { return callContext.fail( throwOnFailure, - "Unsupported argument type. Expected nullable type of root '%s' but actual type was '%s'.", + "Unsupported argument type. Expected NOT NULL type of root '%s' but actual type was '%s'.", expectedRoot, actualType); } diff --git a/flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/inference/InputTypeStrategiesTest.java b/flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/inference/InputTypeStrategiesTest.java index d49e376107fc5..e6973c3e0d0a7 100644 --- a/flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/inference/InputTypeStrategiesTest.java +++ b/flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/inference/InputTypeStrategiesTest.java @@ -543,7 +543,7 @@ ANY, explicit(DataTypes.INT()) .calledWithArgumentTypes(DataTypes.VARCHAR(5)) .expectSignature("f()") .expectErrorMessage( - "Unsupported argument type. Expected nullable type of root 'VARCHAR' but actual type was 'VARCHAR(5)'."), + "Unsupported argument type. Expected NOT NULL type of root 'VARCHAR' but actual type was 'VARCHAR(5)'."), TestSpec.forStrategy( "Logical type family instead of concrete data types", sequence(