Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id A44AD200CFD for ; Wed, 6 Sep 2017 11:48:57 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id A2FD9161198; Wed, 6 Sep 2017 09:48:57 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id E9FD8160CD8 for ; Wed, 6 Sep 2017 11:48:56 +0200 (CEST) Received: (qmail 5753 invoked by uid 500); 6 Sep 2017 09:48:54 -0000 Mailing-List: contact user-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Delivered-To: mailing list user@flink.apache.org Received: (qmail 5738 invoked by uid 99); 6 Sep 2017 09:48:54 -0000 Received: from mail-relay.apache.org (HELO mail-relay.apache.org) (140.211.11.15) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 06 Sep 2017 09:48:54 +0000 Received: from mail-oi0-f46.google.com (mail-oi0-f46.google.com [209.85.218.46]) by mail-relay.apache.org (ASF Mail Server at mail-relay.apache.org) with ESMTPSA id AD5F61A00A5 for ; Wed, 6 Sep 2017 09:48:53 +0000 (UTC) Received: by mail-oi0-f46.google.com with SMTP id n18so38716020oig.2 for ; Wed, 06 Sep 2017 02:48:52 -0700 (PDT) X-Gm-Message-State: AHPjjUjEn/QsVi9ujeE2YXZtGRNivbtTXYpi+Tjh8qqIZS4mOSElgT20 zmQ7kbBGdPbQcAvF7/dVdm1fC31MDg== X-Google-Smtp-Source: ADKCNb7Kf5UkIjNmaOHq9I6ge5Q3pWcaBp2zdHFhqFz0mSOq51WIQGDRGmftSI8O14Pl40lk/QBf97IGVYjPDFktDCY= X-Received: by 10.202.77.80 with SMTP id a77mr2372066oib.318.1504691331734; Wed, 06 Sep 2017 02:48:51 -0700 (PDT) MIME-Version: 1.0 From: =?UTF-8?Q?Gyula_F=C3=B3ra?= Date: Wed, 06 Sep 2017 09:48:41 +0000 X-Gmail-Original-Message-ID: Message-ID: Subject: Empty state restore seems to be broken for Kafka source (1.3.2) To: user Content-Type: multipart/alternative; boundary="001a1134eef4532db205588240d9" archived-at: Wed, 06 Sep 2017 09:48:57 -0000 --001a1134eef4532db205588240d9 Content-Type: text/plain; charset="UTF-8" Hi all, We are running into some problems with the kafka source after changing the uid and restoring from the savepoint. What we are expecting is to clear the partition state, and set it up all over again, but what seems to happen is that the consumer thinks that it doesnt have any partitions assigned. This was supposed to be fixed in https://github.com/apache/flink/commit/0ecb5d0050b84ba48105836288d43ce4c4749459#diff-06bf4a7f73d98ef91309154654563475 but appears to be reworked/reverted in the latest release : https://github.com/apache/flink/blob/0399beed1ea3e04d332b42cc506041d75a6148b4/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java#L547 What is the expected behaviour here? Thanks! Gyula --001a1134eef4532db205588240d9 Content-Type: text/html; charset="UTF-8" Content-Transfer-Encoding: quoted-printable
Hi all,

We are running into some proble= ms with the kafka source after changing the uid and restoring from the save= point.
What we are expecting is to clear the partition state, and= set it up all over again, but what seems to happen is that the consumer th= inks that it doesnt have any partitions assigned.


What is the expected behaviour here?

Thanks= !
Gyula
--001a1134eef4532db205588240d9--