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 8AD3B200BA8 for ; Mon, 24 Oct 2016 19:25:27 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 894C6160B00; Mon, 24 Oct 2016 17:25:27 +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 AA8A5160AEB for ; Mon, 24 Oct 2016 19:25:26 +0200 (CEST) Received: (qmail 28067 invoked by uid 500); 24 Oct 2016 17:25:25 -0000 Mailing-List: contact user-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@flink.apache.org Delivered-To: mailing list user@flink.apache.org Received: (qmail 28051 invoked by uid 99); 24 Oct 2016 17:25:25 -0000 Received: from mail-relay.apache.org (HELO mail-relay.apache.org) (140.211.11.15) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 24 Oct 2016 17:25:25 +0000 Received: from mail-yw0-f182.google.com (mail-yw0-f182.google.com [209.85.161.182]) by mail-relay.apache.org (ASF Mail Server at mail-relay.apache.org) with ESMTPSA id 6EA191A0015 for ; Mon, 24 Oct 2016 17:25:25 +0000 (UTC) Received: by mail-yw0-f182.google.com with SMTP id t193so197735564ywc.2 for ; Mon, 24 Oct 2016 10:25:25 -0700 (PDT) X-Gm-Message-State: ABUngvc7qohw/4Qc5hKOHrqYxJl/aCq5sjyxJIMjyuRf+yw+ymlzKLDZEocgdjq2b7WWzdT3A7mUUmk/henoeA== X-Received: by 10.107.197.66 with SMTP id v63mr13805508iof.119.1477329924675; Mon, 24 Oct 2016 10:25:24 -0700 (PDT) MIME-Version: 1.0 References: <1477060921318-9674.post@n4.nabble.com> In-Reply-To: <1477060921318-9674.post@n4.nabble.com> From: Aljoscha Krettek Date: Mon, 24 Oct 2016 17:25:14 +0000 X-Gmail-Original-Message-ID: Message-ID: Subject: Re: FlinkKafkaConsumerBase - Received confirmation for unknown checkpoint To: user@flink.apache.org, Robert Metzger Content-Type: multipart/alternative; boundary=94eb2c18a3de606dfd053f9fadb1 archived-at: Mon, 24 Oct 2016 17:25:27 -0000 --94eb2c18a3de606dfd053f9fadb1 Content-Type: text/plain; charset=UTF-8 @Robert, do you have any idea what might be going on here? On Fri, 21 Oct 2016 at 16:50 PedroMrChaves wrote: > Hello, > > Am getting the following warning upon executing a checkpoint > > /2016-10-21 16:31:54,229 INFO > org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Triggering > checkpoint 5 @ 1477063914229 > 2016-10-21 16:31:54,233 INFO > org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Completed > checkpoint 5 (in 3 ms) > 2016-10-21 16:31:54,234 WARN > org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase - > Received confirmation for unknown checkpoint id 5/ > > This is the code I have to setup the environment and the kafka consumer: > > / /** > * Flink execution environment configuration > */ > private void setupEnvironmnet() { > environment = StreamExecutionEnvironment.getExecutionEnvironment(); > environment.enableCheckpointing(CHECKPOINTING_INTERVAL); > tableEnvironment = > TableEnvironment.getTableEnvironment(environment); > > } > > /** > * Kafka Consumer configuration > */ > private void kafkaConsumer(String server, String topic) { > Properties properties = new Properties(); > properties.setProperty("bootstrap.servers", server); > properties.setProperty("group.id", "Demo"); > stream = environment.addSource(new FlinkKafkaConsumer09<>(topic, > new > SimpleStringSchema(), properties)) > .map(new Parser()); > }/ > > > Any idea what the problem might be? > > Thank you and regards, > Pedro Chaves > > > > -- > View this message in context: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/FlinkKafkaConsumerBase-Received-confirmation-for-unknown-checkpoint-tp9674.html > Sent from the Apache Flink User Mailing List archive. mailing list archive > at Nabble.com. > --94eb2c18a3de606dfd053f9fadb1 Content-Type: text/html; charset=UTF-8 Content-Transfer-Encoding: quoted-printable
@Robert, do you have any idea what might be going on here?=

On Fri, 21 Oct 2016 at = 16:50 PedroMrChaves <pedro.= mr.chaves@gmail.com> wrote:
= Hello,

Am getting the following warning upon executing a checkpoint

/2016-10-21 16:31:54,229 INFO
org.apache.flink.runtime.checkpoint.CheckpointCoordinator=C2=A0 =C2=A0 =C2= =A0- Triggering
checkpoint 5 @ 1477063914229
2016-10-21 16:31:54,233 INFO
org.apache.flink.runtime.checkpoint.CheckpointCoordinator=C2=A0 =C2=A0 =C2= =A0- Completed
checkpoint 5 (in 3 ms)
2016-10-21 16:31:54,234 WARN
org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase=C2=A0 -<= br class=3D"gmail_msg"> Received confirmation for unknown checkpoint id 5/

This is the code I have to setup the environment and the kafka consumer:
=C2=A0/ /**
=C2=A0 =C2=A0 =C2=A0* Flink execution environment configuration
=C2=A0 =C2=A0 =C2=A0*/
=C2=A0 =C2=A0 private void setupEnvironmnet() {
=C2=A0 =C2=A0 =C2=A0 =C2=A0 environment =3D StreamExecutionEnvironment.getE= xecutionEnvironment();
=C2=A0 =C2=A0 =C2=A0 =C2=A0 environment.enableCheckpointing(CHECKPOINTING_I= NTERVAL);
=C2=A0 =C2=A0 =C2=A0 =C2=A0 tableEnvironment =3D
TableEnvironment.getTableEnvironment(environment);

=C2=A0 =C2=A0 }

=C2=A0 =C2=A0 /**
=C2=A0 =C2=A0 =C2=A0* Kafka Consumer configuration
=C2=A0 =C2=A0 =C2=A0*/
=C2=A0 =C2=A0 private void kafkaConsumer(String server, String topic) {
=C2=A0 =C2=A0 =C2=A0 =C2=A0 Properties properties =3D new Properties();
=C2=A0 =C2=A0 =C2=A0 =C2=A0 properties.setProperty("bootstrap.servers&= quot;, server);
=C2=A0 =C2=A0 =C2=A0 =C2=A0 properties.setProperty("group.id= ", "Demo");
=C2=A0 =C2=A0 =C2=A0 =C2=A0 stream =3D environment.addSource(new FlinkKafka= Consumer09<>(topic, new
SimpleStringSchema(), properties))
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 .map(new Parser());=
=C2=A0 =C2=A0 }/


Any idea what the problem might be?

Thank you and regards,
Pedro Chaves



--
View this message in context: http://apache-flink-user-mailing-list-archive.2336050= .n4.nabble.com/FlinkKafkaConsumerBase-Received-confirmation-for-unknown-che= ckpoint-tp9674.html
Sent from the Apache Flink User Mailing List archive. mailing list archive = at Nabble.com.
--94eb2c18a3de606dfd053f9fadb1--