Narrow the scope of waiting pending task count upon dynamic property reload
Closed this issue · 1 comments
ocadaruma commented
- Currently, Decaton's dynamic property reload is implemented like below:
- When dynamic-property change is detected, up "reloadRequested" flag: https://github.com/line/decaton/blob/v5.0.1/processor/src/main/java/com/linecorp/decaton/processor/runtime/internal/PartitionContexts.java#L74
- Wait all pending tasks are processed
- After that, recreating partition contexts with new concurrency count
Though this "safepoint"-like mechanism was to preserve per-key process ordering guarantee even on concurrency change, at least, we can narrow down the scope of safepoint to per-partition instead of global without violating per-key ordering guarantee.
ta7uw commented
Let me work on this issue!