[
https://issues.apache.org/jira/browse/FLINK-17708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17124731#comment-17124731
]
xiemeilong commented on FLINK-17708:
------------------------------------
Sorry，I only upgraded the jar，but forgot to upgrade the cluster.
> 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)
