flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Aljoscha Krettek <aljos...@apache.org>
Subject Re: FlinkKafkaConsumerBase - Received confirmation for unknown checkpoint
Date Mon, 24 Oct 2016 17:25:14 GMT
@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     - 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.
>

Mime
View raw message