This is an automated email from the ASF dual-hosted git repository.
kfaraz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git.
from 70c40c4 Fix long overflow in SegmentCostCache.Bucket.toLocalInterval
(#12257)
add 1ec57cb Improve kinesis task assignment after resharding (#12235)
No new revisions were added by this update.
Summary of changes:
.../indexing/kinesis/KinesisRecordSupplier.java | 56 +++++++++++++------
.../kinesis/supervisor/KinesisSupervisor.java | 65 ++++++++++++++++++++++
.../supervisor/KinesisSupervisorTuningConfig.java | 13 ++++-
.../kinesis/KinesisIndexTaskTuningConfigTest.java | 1 +
.../kinesis/KinesisRecordSupplierTest.java | 53 ++++++++++++++++++
.../kinesis/supervisor/KinesisSupervisorTest.java | 55 ++++++++++++++++++
.../seekablestream/common/RecordSupplier.java | 4 +-
.../supervisor/SeekableStreamSupervisor.java | 26 ++++++++-
.../druid/testing/utils/KinesisAdminClient.java | 2 +-
9 files changed, 253 insertions(+), 22 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
