autophagy commented on code in PR #27928:
URL: https://github.com/apache/flink/pull/27928#discussion_r3256962122
##########
flink-table/flink-table-test-utils/src/main/java/org/apache/flink/table/runtime/functions/ProcessTableFunctionTestHarness.java:
##########
@@ -309,26 +354,84 @@ private void invokeEval(ArgumentInfo activeTableArg, Row
activeRow) throws Excep
try {
evalMethod.invoke(function, args);
+ } catch (IllegalArgumentException e) {
Review Comment:
I think its unnecessary there too actually, as passing in a table argument
means its chained through InputType -> RowData -> Defined Table Argument Type.
The type mismatch would be found there, not during the invoke
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
