Hi Pedro, The message is a bit unexpected for me as well, but it does not make the checkpointing inconsistent. The only thing that's not happening in case of this warning is that the offsets are not written to Zookeeper.
Which Flink version are you using? On Mon, Oct 24, 2016 at 7:25 PM, Aljoscha Krettek <[email protected]> wrote: > @Robert, do you have any idea what might be going on here? > > > On Fri, 21 Oct 2016 at 16:50 PedroMrChaves <[email protected]> > 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. >> >
