This is an automated email from the ASF dual-hosted git repository.
cwylie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git.
from dcee99d Improve error message when buckets are null for cloud objects
(#11644)
add 9efa6cc Make persists concurrent with adding rows in batch ingestion
(#11536)
No new revisions were added by this update.
Summary of changes:
docs/configuration/index.md | 2 +-
.../druid/indexing/kafka/KafkaIndexTaskTest.java | 3 +-
.../indexing/kinesis/KinesisIndexTaskTest.java | 3 +-
.../druid/indexing/common/config/TaskConfig.java | 54 +-
.../indexing/common/task/BatchAppenderators.java | 58 +-
.../druid/indexing/common/TaskToolboxTest.java | 3 +-
.../AppenderatorDriverRealtimeIndexTaskTest.java | 3 +-
.../indexing/common/task/AppenderatorsTest.java | 534 ++++++++++++++++++
.../common/task/BatchAppenderatorsTest.java | 627 +++++++++++++++++++++
.../common/task/CompactionTaskRunTest.java | 15 +-
.../indexing/common/task/CompactionTaskTest.java | 15 +-
.../druid/indexing/common/task/HadoopTaskTest.java | 3 +-
.../indexing/common/task/IngestionTestBase.java | 3 +-
.../common/task/RealtimeIndexTaskTest.java | 3 +-
.../common/task/TestAppenderatorsManager.java | 62 +-
.../AbstractParallelIndexSupervisorTaskTest.java | 33 +-
.../indexing/overlord/ForkingTaskRunnerTest.java | 9 +-
.../overlord/SingleTaskBackgroundRunnerTest.java | 3 +-
.../druid/indexing/overlord/TaskLifecycleTest.java | 3 +-
.../indexing/overlord/ThreadingTaskRunnerTest.java | 3 +-
.../indexing/worker/WorkerTaskManagerTest.java | 3 +-
.../indexing/worker/WorkerTaskMonitorTest.java | 3 +-
...ocalIntermediaryDataManagerAutoCleanupTest.java | 3 +-
...ermediaryDataManagerManualAddAndDeleteTest.java | 3 +-
.../shuffle/ShuffleDataSegmentPusherTest.java | 3 +-
.../worker/shuffle/ShuffleResourceTest.java | 3 +-
.../realtime/appenderator/Appenderator.java | 2 +-
...reamAppenderator.java => AppenderatorImpl.java} | 112 +++-
.../realtime/appenderator/Appenderators.java | 91 ++-
.../appenderator/AppenderatorsManager.java | 29 +-
.../realtime/appenderator/BatchAppenderator.java | 460 +++++++++------
.../DefaultOfflineAppenderatorFactory.java | 5 +-
.../DummyForInjectionAppenderatorsManager.java | 37 +-
.../appenderator/PeonAppenderatorsManager.java | 73 ++-
.../UnifiedIndexerAppenderatorsManager.java | 80 ++-
...ClosedSegmensSinksBatchAppenderatorTester.java} | 25 +-
...dSegmentsSinksBatchAppenderatorDriverTest.java} | 8 +-
... ClosedSegmentsSinksBatchAppenderatorTest.java} | 250 ++++----
.../DefaultOfflineAppenderatorFactoryTest.java | 8 +-
...> OpenAndClosedSegmentsAppenderatorTester.java} | 188 +++---
...ClosedSegmentsBatchAppenderatorDriverTest.java} | 59 +-
...OpenAndClosedSegmentsBatchAppenderatorTest.java | 229 ++++++++
.../UnifiedIndexerAppenderatorsManagerTest.java | 53 +-
43 files changed, 2560 insertions(+), 606 deletions(-)
create mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/common/task/AppenderatorsTest.java
create mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/common/task/BatchAppenderatorsTest.java
copy
server/src/main/java/org/apache/druid/segment/realtime/appenderator/{StreamAppenderator.java
=> AppenderatorImpl.java} (92%)
rename
server/src/test/java/org/apache/druid/segment/realtime/appenderator/{BatchAppenderatorTester.java
=> ClosedSegmensSinksBatchAppenderatorTester.java} (96%)
copy
server/src/test/java/org/apache/druid/segment/realtime/appenderator/{BatchAppenderatorDriverTest.java
=> ClosedSegmentsSinksBatchAppenderatorDriverTest.java} (96%)
rename
server/src/test/java/org/apache/druid/segment/realtime/appenderator/{BatchAppenderatorTest.java
=> ClosedSegmentsSinksBatchAppenderatorTest.java} (86%)
copy
server/src/test/java/org/apache/druid/segment/realtime/appenderator/{StreamAppenderatorTester.java
=> OpenAndClosedSegmentsAppenderatorTester.java} (60%)
rename
server/src/test/java/org/apache/druid/segment/realtime/appenderator/{BatchAppenderatorDriverTest.java
=> OpenAndClosedSegmentsBatchAppenderatorDriverTest.java} (79%)
create mode 100644
server/src/test/java/org/apache/druid/segment/realtime/appenderator/OpenAndClosedSegmentsBatchAppenderatorTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
