[
https://issues.apache.org/jira/browse/FLINK-17708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17123569#comment-17123569
]
Jark Wu commented on FLINK-17708:
---------------------------------
Did you triy to use 1.10.1? What do you mean "occurred when submit task to
cluster，not in local mode." IMO, this exception should only happen in client
side, not during runtime.
> ScalarFunction has different classloader after submit task jar to cluster。
> --------------------------------------------------------------------------
>
> Key: FLINK-17708
> URL: https://issues.apache.org/jira/browse/FLINK-17708
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Planner
> Affects Versions: 1.10.1
> Reporter: xiemeilong
> Priority: Major
>
> The issue is similar to FLINK-16662
> Only occurred when submit task to cluster， not in local mode.
>
> {code:java}
> Caused by: org.apache.flink.table.api.ValidationException: Given parameters
> of function 'generateDecoder' do not match any signature.
> Actual: (com.yunmo.iot.schema.RecordFormat, com.yunmo.iot.schema.Schema)
> Expected: (com.yunmo.iot.schema.RecordFormat, com.yunmo.iot.schema.Schema)
> {code}
>
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
