This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit b96e67ad1d338b140103f25c9d6f077d555f2dff Author: Stephan Ewen <[email protected]> AuthorDate: Thu Apr 1 17:45:27 2021 +0200 [hotfix][connector/kafka] Fix incorrect lambda --- .../flink/connector/kafka/source/enumerator/KafkaSourceEnumerator.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumerator.java b/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumerator.java index eba276b..b8f2728 100644 --- a/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumerator.java +++ b/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumerator.java @@ -279,7 +279,7 @@ public class KafkaSourceEnumerator if (pendingAssignmentForReader != null && !pendingAssignmentForReader.isEmpty()) { // Put pending assignment into incremental assignment incrementalAssignment - .computeIfAbsent(pendingReader, ArrayList::new) + .computeIfAbsent(pendingReader, (ignored) -> new ArrayList<>()) .addAll(pendingAssignmentForReader); // Make pending partitions as already assigned
