(flink) branch master updated: [hotfix][table] Fix incorrect error message of `RootArgumentTypeStrategy`

[snuyanzin]

This is an automated email from the ASF dual-hosted git repository.

snuyanzin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 883e33b08b9 [hotfix][table] Fix incorrect error message of 
`RootArgumentTypeStrategy`
883e33b08b9 is described below

commit 883e33b08b959e6b0569d89fa4840b8f9e7c300d
Author: dylanhz <53137516+dyla...@users.noreply.github.com>
AuthorDate: Thu Dec 18 05:49:10 2025 +0800

    [hotfix][table] Fix incorrect error message of `RootArgumentTypeStrategy`
---
 .../table/types/inference/strategies/RootArgumentTypeStrategy.java      | 2 +-
 .../org/apache/flink/table/types/inference/InputTypeStrategiesTest.java | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

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 26799805aa1..3658d1fbdb4 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 final class RootArgumentTypeStrategy implements 
ArgumentTypeStrategy {
         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 d49e376107f..e6973c3e0d0 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 @@ class InputTypeStrategiesTest extends 
InputTypeStrategiesTestBase {
                         .calledWithArgumentTypes(DataTypes.VARCHAR(5))
                         .expectSignature("f(<VARCHAR NOT NULL>)")
                         .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(