flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From PedroMrChaves <pedro.mr.cha...@gmail.com>
Subject FlinkKafkaConsumerBase - Received confirmation for unknown checkpoint
Date Fri, 21 Oct 2016 14:42:01 GMT
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