You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tw...@apache.org on 2020/05/20 07:03:13 UTC
[flink] 03/04: [hotfix][table-planner-blink] Fix exception for
invalid function signature
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 <tw...@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);
}