You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Aljoscha Krettek (Jira)" <ji...@apache.org> on 2019/09/04 10:02:00 UTC
[jira] [Closed] (FLINK-13586) Method ClosureCleaner.clean broke
backward compatibility between 1.8.0 and 1.8.1
[ 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)