This is an automated email from the ASF dual-hosted git repository.
jihoonson pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git.
from 4c90c0c Adding more debug logs to increase visibility into
StreamSupervisor notices queue size and processing time. (#11415)
add 7e61042 Bound memory utilization for dynamic partitioning (i.e.
memory growth is constant) (#11294)
No new revisions were added by this update.
Summary of changes:
docs/configuration/index.md | 2 +-
indexing-service/pom.xml | 11 +-
.../druid/indexing/common/config/TaskConfig.java | 10 +-
.../indexing/common/task/BatchAppenderators.java | 2 +-
.../appenderator/BatchAppenderatorTest.java | 233 ----
.../appenderator/BatchAppenderatorTester.java | 293 -----
.../common/task/TestAppenderatorsManager.java | 4 +-
.../SeekableStreamIndexTaskTestBase.java | 4 +-
.../realtime/appenderator/Appenderator.java | 15 +-
.../realtime/appenderator/Appenderators.java | 35 +-
.../appenderator/AppenderatorsManager.java | 2 +-
.../appenderator/BaseAppenderatorDriver.java | 6 +-
.../realtime/appenderator/BatchAppenderator.java | 1147 ++++++++++++++++++++
.../DummyForInjectionAppenderatorsManager.java | 2 +-
.../appenderator/PeonAppenderatorsManager.java | 4 +-
...penderatorImpl.java => StreamAppenderator.java} | 101 +-
.../UnifiedIndexerAppenderatorsManager.java | 11 +-
.../appenderator/AppenderatorPlumberTest.java | 21 +-
.../appenderator/BatchAppenderatorDriverTest.java | 46 +-
.../appenderator/BatchAppenderatorTest.java | 918 ++++++++++++++++
.../appenderator/BatchAppenderatorTester.java | 503 +++++++++
.../DefaultOfflineAppenderatorFactoryTest.java | 14 +-
.../StreamAppenderatorDriverFailTest.java | 6 -
.../appenderator/StreamAppenderatorDriverTest.java | 8 +-
...eratorTest.java => StreamAppenderatorTest.java} | 218 ++--
...orTester.java => StreamAppenderatorTester.java} | 14 +-
.../appenderator/TestUsedSegmentChecker.java | 9 +-
27 files changed, 2823 insertions(+), 816 deletions(-)
delete mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/appenderator/BatchAppenderatorTest.java
delete mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/appenderator/BatchAppenderatorTester.java
create mode 100644
server/src/main/java/org/apache/druid/segment/realtime/appenderator/BatchAppenderator.java
rename
server/src/main/java/org/apache/druid/segment/realtime/appenderator/{AppenderatorImpl.java
=> StreamAppenderator.java} (93%)
create mode 100644
server/src/test/java/org/apache/druid/segment/realtime/appenderator/BatchAppenderatorTest.java
create mode 100644
server/src/test/java/org/apache/druid/segment/realtime/appenderator/BatchAppenderatorTester.java
rename
server/src/test/java/org/apache/druid/segment/realtime/appenderator/{AppenderatorTest.java
=> StreamAppenderatorTest.java} (83%)
rename
server/src/test/java/org/apache/druid/segment/realtime/appenderator/{AppenderatorTester.java
=> StreamAppenderatorTester.java} (97%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
