Checkpointing not happening with keyBy() and value state variable

[Ranjit]

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 ?