Skip to content

Commit 883e33b

Browse files
authored
[hotfix][table] Fix incorrect error message of RootArgumentTypeStrategy
1 parent b289496 commit 883e33b

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/RootArgumentTypeStrategy.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,7 @@ public Optional<DataType> inferArgumentType(
6161
if (Objects.equals(expectedNullability, Boolean.FALSE) && actualType.isNullable()) {
6262
return callContext.fail(
6363
throwOnFailure,
64-
"Unsupported argument type. Expected nullable type of root '%s' but actual type was '%s'.",
64+
"Unsupported argument type. Expected NOT NULL type of root '%s' but actual type was '%s'.",
6565
expectedRoot,
6666
actualType);
6767
}

flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/inference/InputTypeStrategiesTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -543,7 +543,7 @@ ANY, explicit(DataTypes.INT())
543543
.calledWithArgumentTypes(DataTypes.VARCHAR(5))
544544
.expectSignature("f(<VARCHAR NOT NULL>)")
545545
.expectErrorMessage(
546-
"Unsupported argument type. Expected nullable type of root 'VARCHAR' but actual type was 'VARCHAR(5)'."),
546+
"Unsupported argument type. Expected NOT NULL type of root 'VARCHAR' but actual type was 'VARCHAR(5)'."),
547547
TestSpec.forStrategy(
548548
"Logical type family instead of concrete data types",
549549
sequence(

0 commit comments

Comments
 (0)