[flink] 03/04: [hotfix][table-planner-blink] Fix exception for invalid function signature

[twalthr]

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

twalthr pushed a commit to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 41b17a8e75319cb265d9daf89a55e143eff11d10
Author: Timo Walther <twal...@apache.org>
AuthorDate: Mon May 18 13:04:17 2020 +0200

    [hotfix][table-planner-blink] Fix exception for invalid function signature
---
 .../planner/functions/inference/TypeInferenceOperandInference.java     | 3 +++
 1 file changed, 3 insertions(+)

diff --git 
a/flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/inference/TypeInferenceOperandInference.java
 
b/flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/inference/TypeInferenceOperandInference.java
index e8d0aee..75255b8 100644
--- 
a/flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/inference/TypeInferenceOperandInference.java
+++ 
b/flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/inference/TypeInferenceOperandInference.java
@@ -19,6 +19,7 @@
 package org.apache.flink.table.planner.functions.inference;
 
 import org.apache.flink.annotation.Internal;
+import org.apache.flink.table.api.ValidationException;
 import org.apache.flink.table.catalog.DataTypeFactory;
 import org.apache.flink.table.functions.FunctionDefinition;
 import org.apache.flink.table.planner.calcite.FlinkTypeFactory;
@@ -69,6 +70,8 @@ public final class TypeInferenceOperandInference implements 
SqlOperandTypeInfere
                        returnType);
                try {
                        
inferOperandTypesOrError(unwrapTypeFactory(callBinding), callContext, 
operandTypes);
+               } catch (ValidationException e) {
+                       // let operand checker fail
                } catch (Throwable t) {
                        throw createUnexpectedException(callContext, t);
                }