Re: A litte doubt about the usage of checkpointLock

2018-08-14 Thread Andrey Zagrebin
Hi, there are at least 3 main players which use the lock to sync state access between each other: thread processing records in user code, checkpointing thread and processing timers callback thread. I would still recommend to follow the contract and use the lock where required (e.g. custom sour

A litte doubt about the usage of checkpointLock

2018-08-14 Thread aitozi
Hi, community I see the checkpointLock is used in StreamTask to ensure that we don't have concurrent method calls that void consistent checkpoints. As i known, it is used in the data consume , state interactive and the timerService, But I am doubt that, if an application don't enable the checkpoi