My understanding of store changelog is that, each task writes store changes
to a particular changelog partition for that task. (Does that mean the
changelog keys are task names?)
One thing that confuses me is that, the last offsets of some changelog
partitions do not move. I'm using the kafka GetO
Not sure if it is configurable. But you should be able to find an entry in
your samza log like this:
/data/b/yarn/nm/usercache/david/appcache/application_1464853403568_0010/container_e04_1464853403568_0010_01_02/state/session-store/Partition_14
On Fri, Jun 10, 2016 at 7:01 PM, Jack Huang wro
