[ https://issues.apache.org/jira/browse/FLINK-13586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Aljoscha Krettek closed FLINK-13586. ------------------------------------ Resolution: Fixed Resolved on release-1.8 in 655c78f31b45ec3a96e53e269fca64b4682025ff > 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 > Components: API / DataStream > Affects Versions: 1.8.1, 1.9.0, 1.10.0 > Reporter: Gaël Renoux > Assignee: Aljoscha Krettek > Priority: Major > Labels: pull-request-available > Fix For: 1.8.2 > > Time Spent: 20m > Remaining Estimate: 0h > > 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 (v8.3.2#803003)