Hello Stefan, 

Thank you for the help.

I've actually lost those logs to due several cluster restarts that we did,
which cause log rotation up (limit = 5 versions).
Those log lines that i've posted were the only ones that showed signs of
some problem. 

*The configuration of the job is as follows:*

/ private static final int DEFAULT_MAX_PARALLELISM = 16;
    private static final int CHECKPOINTING_INTERVAL = 1000;
    private static final int MIN_PAUSE_BETWEEN_CHECKPOINTS = 1000;
    private static final int CHECKPOINT_TIMEOUT = 60000;
    private static final int INTERVAL_BETWEEN_RESTARTS = 120; 
(...)

  environment.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);
        environment.setMaxParallelism(DEFAULT_MAX_PARALLELISM);
        environment.enableCheckpointing(CHECKPOINTING_INTERVAL,
CheckpointingMode.EXACTLY_ONCE);
       
environment.getCheckpointConfig().setMinPauseBetweenCheckpoints(MIN_PAUSE_BETWEEN_CHECKPOINTS);
       
environment.getCheckpointConfig().setCheckpointTimeout(CHECKPOINT_TIMEOUT);
        environment.setRestartStrategy(RestartStrategies.noRestart());
        environment.setParallelism(parameters.getInt(JOB_PARALLELISM));/
*
the kafka consumer/producer configuration is:*
/
        properties.put("value.deserializer",
"org.apache.kafka.common.serialization.StringDeserializer");
        properties.put("max.request.size","1579193");
        properties.put("processing.guarantee","exactly_once");
        properties.put("isolation.level","read_committed");/



-----
Best Regards,
Pedro Chaves
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Reply via email to