flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Robert Metzger <rmetz...@apache.org>
Subject Re: FlinkKafkaConsumerBase - Received confirmation for unknown checkpoint
Date Wed, 26 Oct 2016 08:35:16 GMT
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 <aljoscha@apache.org>
wrote:

> @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