Checkpointing not happening with keyBy() and value state variable

Posted by Ranjit on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Checkpointing-not-happening-with-keyBy-and-value-state-variable-tp9236.html

Hi,
Attached are the code snippet files.  The Same code works when I removed keyBy() and state variables from my program, I can see trigger checkpointing and completion event logs.
I am using Flink 1.1.1 version.
FlinkStateManager.javaMessageFormatter.javaSink.javastateLogs.txt

From my previous readings below are the factors which could affect checkpointing:
1)Large state in Operator
2)Any Operator taking lot of time to complete

Can keyBy() affect checkpointing ?