Closed adithyachakilam closed 1 week ago
@suneet-s Thanks for the review, I've changed the patch to just update the min/max times once every task duration. So this also avoids all those version problems.
Overruling CI. I had to re-trigger a bunch of failed ITs, and now they have all passed. The only remaining failures are code coverage.
Description
In cases where
stopTasksCount
is configured which makes streaming tasks run much longer (in some cases) than the configured task duration, early/late rejection periods are not correctly implemented since they are configured during the task startup time in IOConfig. Instead, this PR propagates updates the min/max times once every task duration.Key changed/added classes in this PR
SeekableStreamIndexTaskRunner
SeekableStreamIndexTaskIOConfig
This PR has: