You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "xiemeilong (Jira)" <ji...@apache.org> on 2020/06/03 08:07:00 UTC
[jira] [Closed] (FLINK-17708) ScalarFunction has different classloader after submit task jar to cluster。
[ https://issues.apache.org/jira/browse/FLINK-17708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
xiemeilong closed FLINK-17708.
------------------------------
Resolution: Not A Bug
> 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)