This is an automated email from the ASF dual-hosted git repository.
suneet pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git
from 24a1fafaa74 projection segment merge fixes (#17460)
add 6f436301bee supervisor: make rejection periods work with
stopTasksCount (#17442)
No new revisions were added by this update.
Summary of changes:
docs/ingestion/supervisor.md | 2 +-
.../RabbitStreamIndexTaskIOConfig.java | 8 +-
.../supervisor/RabbitStreamSupervisor.java | 5 +-
.../supervisor/RabbitStreamSupervisorTest.java | 47 ++++
.../indexing/kafka/KafkaIndexTaskIOConfig.java | 12 +-
.../indexing/kafka/supervisor/KafkaSupervisor.java | 3 +-
.../druid/indexing/kafka/KafkaIndexTaskTest.java | 160 +++++++++-----
.../kafka/supervisor/KafkaSupervisorTest.java | 7 +-
.../indexing/kinesis/KinesisIndexTaskIOConfig.java | 12 +-
.../kinesis/supervisor/KinesisSupervisor.java | 3 +-
.../indexing/kinesis/KinesisIOConfigTest.java | 4 +-
.../kinesis/KinesisIndexTaskSerdeTest.java | 4 +-
.../indexing/kinesis/KinesisIndexTaskTest.java | 16 +-
.../kinesis/supervisor/KinesisSupervisorTest.java | 4 +-
.../seekablestream/SeekableStreamIndexTask.java | 27 ---
.../SeekableStreamIndexTaskIOConfig.java | 12 +-
.../SeekableStreamIndexTaskRunner.java | 49 ++++-
.../SeekableStreamIndexTaskRunnerAuthTest.java | 4 +-
.../SeekableStreamIndexTaskRunnerTest.java | 242 +++++++++++++++++++++
.../SeekableStreamSupervisorSpecTest.java | 3 +-
.../SeekableStreamSupervisorStateTest.java | 6 +-
21 files changed, 519 insertions(+), 111 deletions(-)
create mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/seekablestream/SeekableStreamIndexTaskRunnerTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
