[
https://issues.apache.org/jira/browse/FLINK-17708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17123547#comment-17123547
]
xiemeilong edited comment on FLINK-17708 at 6/2/20, 9:16 AM:
-------------------------------------------------------------
[[email protected]] [~jark] No other people watching this issue for a
long time. Would you confirm this issue?
was (Author: xiemeilong):
[[email protected]] No other people watching this issue for a long
time. Would you confirm this issue?
> 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)
