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 8a7e7e7 fix balancer + broadcast segments npe (#10021)
add 9a10f83 Set the core partition set size properly for batch ingestion
with dynamic partitioning (#10012)
No new revisions were added by this update.
Summary of changes:
.../partition/BuildingNumberedShardSpec.java | 153 +++++++++++++++++++++
.../partition/NumberedOverwriteShardSpec.java | 21 ++-
.../partition/NumberedPartialShardSpec.java | 7 +
.../timeline/partition/NumberedShardSpec.java | 5 +
.../druid/timeline/partition/PartialShardSpec.java | 8 +-
.../apache/druid/timeline/partition/ShardSpec.java | 35 ++++-
.../druid/timeline/partition/ShardSpecLookup.java | 4 +
.../partition/BuildingNumberedShardSpecTest.java | 93 +++++++++++++
...st.java => NumberedOverwriteShardSpecTest.java} | 35 ++---
.../common/task/LocalSegmentAllocator.java | 4 +-
.../parallel/ParallelIndexSupervisorTask.java | 3 +-
.../common/task/CompactionTaskRunTest.java | 24 ++--
.../parallel/SinglePhaseParallelIndexingTest.java | 92 ++++++++++++-
.../appenderator/SegmentPublisherHelper.java | 107 ++++++++++++++
.../TransactionalSegmentPublisher.java | 60 +-------
15 files changed, 550 insertions(+), 101 deletions(-)
create mode 100644
core/src/main/java/org/apache/druid/timeline/partition/BuildingNumberedShardSpec.java
create mode 100644
core/src/test/java/org/apache/druid/timeline/partition/BuildingNumberedShardSpecTest.java
copy
core/src/test/java/org/apache/druid/timeline/partition/{SingleDimensionPartialShardSpecTest.java
=> NumberedOverwriteShardSpecTest.java} (57%)
create mode 100644
server/src/main/java/org/apache/druid/segment/realtime/appenderator/SegmentPublisherHelper.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
