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.
