You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@druid.apache.org by jo...@apache.org on 2020/03/17 04:40:06 UTC
[druid] branch master updated (7626be2 -> 142742f)
This is an automated email from the ASF dual-hosted git repository.
jonwei pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git.
from 7626be2 Web console: add config control for the query context (#9499)
add 142742f add kinesis lag metric (#9509)
No new revisions were added by this update.
Summary of changes:
.../indexing/kafka/supervisor/KafkaSupervisor.java | 112 +++-----
.../supervisor/KafkaSupervisorReportPayload.java | 2 +
.../supervisor/KafkaSupervisorTuningConfig.java | 3 +-
.../kafka/supervisor/KafkaSupervisorTest.java | 6 +-
.../indexing/kinesis/KinesisRecordSupplier.java | 79 +++++-
.../kinesis/supervisor/KinesisSupervisor.java | 48 ++--
.../supervisor/KinesisSupervisorReportPayload.java | 16 +-
.../supervisor/KinesisSupervisorTuningConfig.java | 17 +-
.../indexing/kinesis/KinesisIndexTaskTest.java | 5 +
.../kinesis/KinesisIndexTaskTuningConfigTest.java | 1 +
.../kinesis/KinesisRecordSupplierTest.java | 110 +++++++-
.../kinesis/supervisor/KinesisSupervisorTest.java | 118 ++++++++-
.../supervisor/SeekableStreamSupervisor.java | 161 ++++++++++--
.../SeekableStreamSupervisorReportPayload.java | 25 +-
.../SeekableStreamSupervisorTuningConfig.java | 5 +-
.../seekablestream/supervisor/TaskReportData.java | 17 +-
.../SeekableStreamSupervisorStateTest.java | 288 ++++++++++++++++++++-
17 files changed, 854 insertions(+), 159 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@druid.apache.org
For additional commands, e-mail: commits-help@druid.apache.org