Guozhang Wang
Guozhang Wang
In remoteaccount.py, there is race condition in `monitor_log` and `wait_until` in which we use `wc -c` and `tail -c`: the file may be still being written to at the time...
1. Within the tryCompleteRestore function of the thread, try to drain the removed tasks from state updater and handle accordingly: 1) for recycle, 2) for closure, 3) for update input...
Unit tests passed locally, do not think it has any compatibility breakage. ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify...
Should only be reviewed after https://github.com/apache/kafka/pull/12387. Needs discussion on KIPs. And also we should only merge this PR after the whole integration is done. I propose adding the following metrics...
Hey Kai, I think you can use `transform` that can return a new stream, with the similar function but return the result `p` as the value and even with a...
When a topology is paused / resumed, we also need to pause / resume its corresponding tasks inside state updater. ### Committer Checklist (excluded from commit message) - [ ]...
We need to have the full information on how the seq / epochs are inferred with logging. ### Committer Checklist (excluded from commit message) - [ ] Verify design and...
### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ] Verify documentation (including...
Hey @zz85 thanks for this great tool! I've been using it for quite some time and it is definitely a big saver. A qq for you: what should I do...
*More detailed description of your change, if necessary. The PR title and PR message become the squashed commit message, so use a separate comment to ping reviewers.* *Summary of testing...