We always create task directories -- this helps to cleanly hand over tasks and detect reassignment issues (via the .lock)
The checkpoint file will be empty if you don't use any state.
-Matthias
On 1/4/18 7:15 PM, Ted Yu wrote:
> Looks like the .checkpoint file was generated from this code in
> ProcessorStateManager
> :
>
> // write the checkpoint file before closing, to indicate clean
> shutdown
>
> try {
>
> if (checkpoint == null) {
>
> checkpoint = new OffsetCheckpoint(new File(baseDir,
> CHECKPOINT_FILE_NAME));
>
>
> FYI
>
> On Thu, Jan 4, 2018 at 11:48 AM, Kristopher Kane <kkane.l...@gmail.com>
> wrote:
>
>> I just noticed /tmp/kafka-streams/<app id>/0_[0,1]/{.checkpoint,.lock]
>> (there are two partitions on the incoming topic) being automatically
>> created during an integration test. My Streams app doesn't use a state
>> store and only contains mapValues and a .to termination operation.
>>
>> Anyone know what this is for?
>>
>> Thanks,
>>
>> Kris
>>
>
signature.asc
Description: OpenPGP digital signature
