[ 
https://issues.apache.org/jira/browse/FLINK-13586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16901096#comment-16901096
 ] 

Victor Wong commented on FLINK-13586:
-------------------------------------

I think it would be helpful to attach [mail 
discussion|https://lists.apache.org/thread.html/56f137a4c0b90eb94a73b7a2ab95453282293cf9c81107e9bedc658a@%3Cuser.flink.apache.org%3E]
 here.  

A user ran into `java.lang.NoSuchMethodError` when trying to submit an 
application packaged with flink 1.8.1 to flink cluster 1.8.0.  
{code:java}
...
Caused by: java.lang.NoSuchMethodError: 
org.apache.flink.api.java.ClosureCleaner.clean(Ljava/lang/Object;Lorg/apache/flink/api/common/ExecutionConfig$ClosureCleanerLevel;Z)V
at 
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer011.<init>(FlinkKafkaProducer011.java:494)
...{code}

> Method ClosureCleaner.clean broke backward compatibility between 1.8.0 and 
> 1.8.1
> --------------------------------------------------------------------------------
>
>                 Key: FLINK-13586
>                 URL: https://issues.apache.org/jira/browse/FLINK-13586
>             Project: Flink
>          Issue Type: Bug
>    Affects Versions: 1.8.1
>            Reporter: Gaël Renoux
>            Priority: Major
>
> Method clean in org.apache.flink.api.java.ClosureCleaner received a new 
> parameter in Flink 1.8.1. This class is noted as internal, but is used in the 
> Kafka connectors (in 
> org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerBase).
> The Kafka connectors library is not provided by the server, and must be set 
> up as a dependency with compile scope (see 
> https://ci.apache.org/projects/flink/flink-docs-stable/dev/connectors/kafka.html#usage,
>  or the Maven project template). Any project using those connectors and built 
> with 1.8.0 cannot be deployed on a 1.8.1 Flink server, because it would 
> target the old method.
> => This methods needs a fallback with the original two arguments (setting a 
> default value of RECURSIVE for the level argument).



--
This message was sent by Atlassian JIRA
(v7.6.14#76016)

Reply via email to