fix

Author: lihaosky

flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/ModelTypeUtils.java

@@ -18,6 +18,7 @@
 
 package org.apache.flink.table.functions;
 
+import org.apache.flink.annotation.Internal;
 import org.apache.flink.table.api.DataTypes;
 import org.apache.flink.table.api.DataTypes.Field;
 import org.apache.flink.table.api.ValidationException;
@@ -40,6 +41,7 @@
 import java.util.Set;
 import java.util.stream.Collectors;
 
+@Internal
 public class ModelTypeUtils {
 
     public static final InputTypeStrategy ML_PREDICT_INPUT_TYPE_STRATEGY =

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

@@ -160,6 +160,6 @@ protected Stream<TestSpec> testData() {
                         .calledWithModelSemanticsAt(
                                 1, new ModelSemanticsMock(MODEL_INPUT_TYPE, MODEL_OUTPUT_TYPE))
                         .expectErrorMessage(
-                                "Third argument must be a descriptor with column names for ML_PREDICT function."));
+                                "Third argument must be a descriptor with simple column names for ML_PREDICT function."));
     }
 }