This is an automated email from the ASF dual-hosted git repository.
FrankChen021 pushed a change to branch dependabot/maven/orc.version-2.3.1
in repository https://gitbox.apache.org/repos/asf/druid.git
omit e6c8e43a9c2 build: align ORC 2.3.1 dependencies
omit 0f6b249f408 build(deps): bump orc.version from 1.7.6 to 2.3.1
add b3f08c83aa0 feat: Allow BINDABLE plans for Dart. (#19952)
add 2b02e7a28ae test: Silence unrelated NPE alerts in DruidCoordinatorTest
(#19953)
add 1bea666b833 fix(test): retry Kafka partition readiness (#19948)
add d083f6e9b99 minor: Add `LeaderOverlordService` and other miscellaneous
things (#19949)
add 7807261c310 test: migrate nine extensions-contrib modules to JUnit 5
(#19908)
add e094711c8fe test(indexing-service): migrate task actions and
compaction tests to JUnit 5 (#19910)
add 7ab19bd5acf test: migrate second extensions-contrib batch to JUnit 5
(#19915)
add 268e23b804b test: migrate third extensions-contrib batch to JUnit 5
(#19916)
add ce852d81344 test: migrate final extensions-contrib batch to JUnit 5
(#19917)
add 007b88d5748 test(indexing-service): migrate common support tests to
JUnit 5 (#19920)
add 18c6e02c971 test(indexing): migrate seekable-stream tests to JUnit 5
(#19923)
add 31fda7f4970 test(indexing-service): migrate worker tests to JUnit 5
(#19925)
add 6446675bf2b test(indexing-service): migrate ingestion and parallel
tests to JUnit 5 (#19926)
add 1309686a456 test: migrate processing batch 1 to JUnit 5 (#19940)
add a92f4b62b8d fix: Don't reopen closed clients in DartWorkerClientImpl.
(#19927)
add 5318badd537 build(deps): bump aws.sdk.v2.version from 2.51.0 to 2.51.3
(#19954)
add ff551e53c15 build(deps): bump org.apache.httpcomponents:httpclient
from 4.5.13 to 4.5.14 (#19955)
add 9e354d4f41b build(deps): bump jetty.version from 12.1.11 to 12.1.12
(#19956)
add 38f372e9adc build(deps): bump org.openrewrite.recipe:rewrite-apache
(#19957)
add b1aa825e032 build(deps): bump commons-io:commons-io from 2.21.0 to
2.22.0 (#19958)
add 3d484e2ff56 build(deps): bump org.ow2.asm:asm from 9.9.1 to 9.10.1
(#19959)
add fb9d24e943a build(deps-dev): bump
io.aiven:testcontainers-fake-gcs-server (#19961)
add 63b4731181c build(deps-dev): bump com.github.fppt:jedis-mock from
1.1.12 to 1.1.17 (#19962)
add e789150875b build(deps): bump org.ow2.asm:asm-commons from 9.9.1 to
9.10.1 (#19964)
add 4c0b58f41ee build(deps): bump com.nimbusds:nimbus-jose-jwt from 9.37.4
to 10.9.1 (#19965)
add ffc3d988c6a build(deps): bump org.checkerframework:checker-qual from
3.49.2 to 4.2.2 (#19967)
add 8c593dadbba build(deps): bump org.apache.hive:hive-storage-api from
2.8.1 to 4.2.0 (#19968)
add f072f5d5273 build(deps): bump apache.ranger.version from 2.8.0 to
2.9.0 (#19969)
add 1a2012d5188 build(deps): bump jmh.version from 1.21 to 1.37 (#19970)
add 99c1a3d955d build(deps): bump
org.apache.maven.extensions:maven-build-cache-extension from 1.2.0 to 1.2.3
(#19973)
add 5dd74a82c38 test(sql): migrate SQL core and schema tests to JUnit 5
(#19939)
add 8a3979412b7 build(deps): bump orc.version from 1.7.6 to 2.3.1
add 8fcf8c3f23e build: align ORC 2.3.1 dependencies
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (e6c8e43a9c2)
\
N -- N -- N refs/heads/dependabot/maven/orc.version-2.3.1
(8fcf8c3f23e)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
AGENTS.md | 17 +
benchmarks/pom.xml | 21 +-
.../benchmark/FlattenJSONBenchmarkUtilTest.java | 120 +--
.../indexing/OnheapIncrementalIndexBenchmark.java | 18 +-
.../timeline/DimensionRangeShardSpecBenchmark.java | 20 +-
cloud/aws-common/pom.xml | 10 -
.../apache/druid/common/aws/AWSClientUtilTest.java | 26 +-
.../druid/common/aws/AWSCredentialsConfigTest.java | 28 +-
cloud/gcp-common/pom.xml | 9 +-
.../org/apache/druid/common/gcp/GcpModuleTest.java | 8 +-
docs/development/extensions-core/bloom-filter.md | 2 +-
embedded-tests/pom.xml | 2 +-
extensions-contrib/aliyun-oss-extensions/pom.xml | 26 +-
.../data/input/aliyun/OssInputSourceTest.java | 185 +++--
.../storage/aliyun/OssDataSegmentArchiverTest.java | 16 +-
.../storage/aliyun/OssDataSegmentKillerTest.java | 14 +-
.../storage/aliyun/OssDataSegmentMoverTest.java | 78 +-
.../storage/aliyun/OssDataSegmentPullerTest.java | 41 +-
.../aliyun/OssDataSegmentPusherConfigTest.java | 8 +-
.../storage/aliyun/OssDataSegmentPusherTest.java | 29 +-
.../aliyun/OssObjectSummaryIteratorTest.java | 10 +-
.../storage/aliyun/OssStorageDruidModuleTest.java | 16 +-
.../druid/storage/aliyun/OssTaskLogsTest.java | 38 +-
.../OssTimestampVersionedDataFinderTest.java | 12 +-
extensions-contrib/ambari-metrics-emitter/pom.xml | 25 +-
.../metrics/AmbariMetricsEmitterConfigTest.java | 14 +-
.../ambari/metrics/AmbariMetricsEmitterTest.java | 26 +-
.../DruidToWhiteListBasedConverterTest.java | 6 +-
...ListBasedDruidToTimelineEventConverterTest.java | 110 ++-
extensions-contrib/cassandra-storage/pom.xml | 6 -
extensions-contrib/cloudfiles-extensions/pom.xml | 20 +-
.../cloudfiles/CloudFilesByteSourceTest.java | 18 +-
.../CloudFilesDataSegmentPusherTest.java | 17 +-
.../cloudfiles/CloudFilesObjectApiProxyTest.java | 12 +-
extensions-contrib/compressed-bigdecimal/pom.xml | 55 +-
.../ArrayCompressedBigDecimalTest.java | 159 ++--
.../ByteBufferCompressedBigDecimalTest.java | 6 +-
.../CompressedBigDecimalCachingTest.java | 6 +-
.../CompressedBigDecimalColumnTest.java | 12 +-
.../CompressedBigDecimalFactoryTestBase.java | 62 +-
.../CompressedBigDecimalMaxFactoryTest.java | 32 +-
.../CompressedBigDecimalMinFactoryTest.java | 32 +-
.../CompressedBigDecimalSumFactoryTest.java | 40 +-
...pressedBigDecimalAggregatorGroupByTestBase.java | 87 +--
.../CompressedBigDecimalAggregatorTestBase.java | 6 +-
...ssedBigDecimalAggregatorTimeseriesTestBase.java | 59 +-
...mpressedBigDecimalMaxAggregatorGroupByTest.java | 10 +-
.../max/CompressedBigDecimalMaxAggregatorTest.java | 2 +
...essedBigDecimalMaxAggregatorTimeseriesTest.java | 3 +
...mpressedBigDecimalMinAggregatorGroupByTest.java | 12 +-
.../min/CompressedBigDecimalMinAggregatorTest.java | 2 +
...essedBigDecimalMinAggregatorTimeseriesTest.java | 3 +
.../CompressedBigDecimalMinSqlAggregatorTest.java | 2 +-
...mpressedBigDecimalSumAggregatorGroupByTest.java | 10 +-
.../sum/CompressedBigDecimalSumAggregatorTest.java | 2 +
...essedBigDecimalSumAggregatorTimeseriesTest.java | 3 +
.../CompressedBigDecimalSumSqlAggregatorTest.java | 2 +-
extensions-contrib/consul-extensions/pom.xml | 20 +-
.../discovery/ConsulClientsSecurityTest.java | 46 +-
.../discovery/ConsulDiscoveryConfigTest.java | 67 +-
.../discovery/ConsulDruidNodeAnnouncerTest.java | 29 +-
.../ConsulDruidNodeDiscoveryProviderTest.java | 24 +-
.../consul/discovery/ConsulLeaderSelectorTest.java | 38 +-
.../consul/discovery/ConsulServiceIdsTest.java | 10 +-
extensions-contrib/ddsketch/pom.xml | 20 +-
.../ddsketch/DDSketchAggregatorFactoryTest.java | 10 +-
.../ddsketch/DDSketchAggregatorTest.java | 59 +-
.../ddsketch/DDSketchObjectStrategyTest.java | 6 +-
.../DDSketchToQuantilePostAggregatorTest.java | 12 +-
.../DDSketchToQuantilesPostAggregatorTest.java | 18 +-
extensions-contrib/distinctcount/pom.xml | 40 +-
.../DistinctCountGroupByQueryTest.java | 23 +-
.../DistinctCountTimeseriesQueryTest.java | 2 +-
.../distinctcount/DistinctCountTopNQueryTest.java | 10 +-
extensions-contrib/dropwizard-emitter/pom.xml | 20 +-
.../dropwizard/DropwizardEmitterConfigTest.java | 42 +-
.../druid-deltalake-extensions/pom.xml | 55 +-
.../org/apache/druid/delta/DeltaAssertions.java | 23 +-
.../druid/delta/filter/DeltaAndFilterTest.java | 35 +-
.../druid/delta/filter/DeltaEqualsFilterTest.java | 35 +-
.../delta/filter/DeltaGreaterThanFilterTest.java | 8 +-
.../filter/DeltaGreaterThanOrEqualsFilterTest.java | 8 +-
.../delta/filter/DeltaLessThanFilterTest.java | 8 +-
.../filter/DeltaLessThanOrEqualsFilterTest.java | 19 +-
.../druid/delta/filter/DeltaNotFilterTest.java | 31 +-
.../druid/delta/filter/DeltaOrFilterTest.java | 35 +-
.../druid/delta/input/DeltaInputRowTest.java | 23 +-
.../delta/input/DeltaInputSourceSerdeTest.java | 28 +-
.../druid/delta/input/DeltaInputSourceTest.java | 169 ++--
.../druid/delta/input/DeltaTimeUtilsTest.java | 16 +-
.../druid-exact-count-bitmap/pom.xml | 16 +-
.../druid-iceberg-extensions/pom.xml | 29 +-
.../druid/iceberg/filter/IcebergAndFilterTest.java | 12 +-
.../iceberg/filter/IcebergEqualsFilterTest.java | 6 +-
.../iceberg/filter/IcebergIntervalFilterTest.java | 6 +-
.../druid/iceberg/filter/IcebergNotFilterTest.java | 10 +-
.../druid/iceberg/filter/IcebergOrFilterTest.java | 14 +-
.../iceberg/filter/IcebergRangeFilterTest.java | 12 +-
.../filter/IcebergTimeWindowFilterTest.java | 6 +-
.../iceberg/input/GlueIcebergCatalogTest.java | 8 +-
.../iceberg/input/HiveIcebergCatalogTest.java | 10 +-
.../iceberg/input/IcebergInputSourceTest.java | 63 +-
.../druid/iceberg/input/LocalCatalogTest.java | 10 +-
.../iceberg/input/ResidualFilterModeTest.java | 26 +-
.../druid/iceberg/input/RestCatalogTest.java | 20 +-
extensions-contrib/druid-ranger-security/pom.xml | 20 +-
.../ranger/authorizer/RangerAuthorizerTest.java | 24 +-
extensions-contrib/gce-extensions/pom.xml | 20 +-
.../autoscaling/gce/GceAutoScalerTest.java | 66 +-
.../overlord/autoscaling/gce/GceUtilsTest.java | 24 +-
extensions-contrib/graphite-emitter/pom.xml | 25 +-
.../DruidToWhiteListBasedConverterTest.java | 8 +-
.../graphite/GraphiteEmitterConfigTest.java | 16 +-
.../graphite/WhiteListBasedConverterTest.java | 111 ++-
extensions-contrib/grpc-query/pom.xml | 30 +-
.../java/org/apache/druid/grpc/BasicAuthTest.java | 11 +-
.../java/org/apache/druid/grpc/DriverTest.java | 9 +-
.../java/org/apache/druid/grpc/GrpcQueryTest.java | 9 +-
.../java/org/apache/druid/grpc/TestServer.java | 14 +-
.../druid/grpc/client/GrpcResponseHandlerTest.java | 6 +-
extensions-contrib/influx-extensions/pom.xml | 35 +-
.../data/input/influx/InfluxInputFormatTest.java | 110 +--
extensions-contrib/influxdb-emitter/pom.xml | 20 +-
.../influxdb/InfluxdbEmitterConfigTest.java | 128 +--
.../emitter/influxdb/InfluxdbEmitterTest.java | 164 ++--
extensions-contrib/kafka-emitter/pom.xml | 30 +-
.../emitter/kafka/KafkaEmitterConfigTest.java | 78 +-
.../druid/emitter/kafka/KafkaEmitterTest.java | 165 ++--
extensions-contrib/momentsketch/pom.xml | 20 +-
.../MomentSketchObjectStrategyTest.java | 6 +-
.../momentsketch/MomentSketchWrapperTest.java | 10 +-
.../MomentSketchAggregatorFactoryTest.java | 16 +-
.../MomentSketchMaxPostAggregatorTest.java | 12 +-
.../MomentSketchMinPostAggregatorTest.java | 12 +-
.../MomentSketchQuantilePostAggregatorTest.java | 30 +-
.../aggregator/MomentsSketchAggregatorTest.java | 67 +-
extensions-contrib/moving-average-query/pom.xml | 30 +-
.../movingaverage/MovingAverageIterableTest.java | 378 +++++----
.../movingaverage/MovingAverageQueryTest.java | 36 +-
.../PostAveragerAggregatorCalculatorTest.java | 14 +-
.../query/movingaverage/RowBucketIterableTest.java | 190 ++---
.../averagers/AveragerFactoryWrapperTest.java | 8 +-
.../averagers/BaseAveragerFactoryTest.java | 14 +-
.../movingaverage/averagers/BaseAveragerTest.java | 76 +-
.../averagers/DoubleMaxAveragerFactoryTest.java | 7 +-
.../averagers/DoubleMaxAveragerTest.java | 16 +-
.../averagers/DoubleMeanAveragerFactoryTest.java | 7 +-
.../averagers/DoubleMeanAveragerTest.java | 16 +-
.../DoubleMeanAveragerWithPeriodTest.java | 14 +-
.../DoubleMeanNoNullAveragerFactoryTest.java | 7 +-
.../averagers/DoubleMeanNoNullAveragerTest.java | 22 +-
.../averagers/DoubleMinAveragerFactoryTest.java | 7 +-
.../averagers/DoubleMinAveragerTest.java | 16 +-
.../averagers/DoubleSumAveragerFactoryTest.java | 7 +-
.../averagers/DoubleSumAveragerTest.java | 16 +-
.../averagers/LongMaxAveragerFactoryTest.java | 7 +-
.../averagers/LongMaxAveragerTest.java | 16 +-
.../averagers/LongMeanAveragerFactoryTest.java | 7 +-
.../averagers/LongMeanAveragerTest.java | 16 +-
.../LongMeanNoNullAveragerFactoryTest.java | 7 +-
.../averagers/LongMeanNoNullAveragerTest.java | 16 +-
.../averagers/LongMinAveragerFactoryTest.java | 7 +-
.../averagers/LongMinAveragerTest.java | 16 +-
.../averagers/LongSumAveragerFactoryTest.java | 7 +-
.../averagers/LongSumAveragerTest.java | 16 +-
extensions-contrib/opentelemetry-emitter/pom.xml | 20 +-
.../opentelemetry/OpenTelemetryEmitterTest.java | 32 +-
extensions-contrib/opentsdb-emitter/pom.xml | 20 +-
.../druid/emitter/opentsdb/EventConverterTest.java | 44 +-
.../opentsdb/OpentsdbEmitterConfigTest.java | 18 +-
.../druid/emitter/opentsdb/OpentsdbEventTest.java | 10 +-
.../druid/emitter/opentsdb/OpentsdbSenderTest.java | 6 +-
extensions-contrib/prometheus-emitter/pom.xml | 20 +-
.../druid/emitter/prometheus/MetricsTest.java | 80 +-
.../prometheus/PrometheusEmitterConfigTest.java | 54 +-
.../emitter/prometheus/PrometheusEmitterTest.java | 138 ++--
.../rabbit-stream-indexing-service/pom.xml | 30 +-
.../RabbitStreamIndexTaskIOConfigTest.java | 30 +-
.../RabbitStreamIndexTaskTuningConfigTest.java | 67 +-
.../RabbitStreamRecordSupplierTest.java | 68 +-
.../RabbitStreamSupervisorIOConfigTest.java | 128 ++-
.../supervisor/RabbitStreamSupervisorTest.java | 80 +-
.../RabbitStreamSupervisorTuningConfigTest.java | 77 +-
extensions-contrib/redis-cache/pom.xml | 32 +-
.../druid/client/cache/RedisCacheConfigTest.java | 147 +---
.../druid/client/cache/RedisClusterCacheTest.java | 51 +-
.../client/cache/RedisStandaloneCacheTest.java | 64 +-
extensions-contrib/spectator-histogram/pom.xml | 55 +-
.../histogram/NullableOffsetsHeaderTest.java | 190 ++---
.../SpectatorHistogramAggregateHelperTest.java | 76 +-
.../SpectatorHistogramAggregatorTest.java | 189 ++---
...ctatorHistogramIndexBasedComplexColumnTest.java | 8 +-
...orHistogramNumericVectorizedAggregatorTest.java | 62 +-
.../histogram/SpectatorHistogramTest.java | 240 +++---
...SpectatorHistogramVectorizedAggregatorTest.java | 66 +-
.../sql/SpectatorHistogramSqlAggregatorTest.java | 10 +-
.../sqlserver-metadata-storage/pom.xml | 21 +-
.../sqlserver/CustomStatementRewriterTest.java | 34 +-
.../storage/sqlserver/SQLServerConnectorTest.java | 30 +-
extensions-contrib/statsd-emitter/pom.xml | 20 +-
.../emitter/statsd/DimensionConverterTest.java | 8 +-
.../druid/emitter/statsd/StatsDEmitterTest.java | 16 +-
extensions-contrib/tdigestsketch/pom.xml | 50 +-
.../TDigestSketchAggregatorFactoryTest.java | 14 +-
.../tdigestsketch/TDigestSketchAggregatorTest.java | 71 +-
.../TDigestSketchObjectStrategyTest.java | 4 +-
.../TDigestSketchToQuantilePostAggregatorTest.java | 16 +-
...TDigestSketchToQuantilesPostAggregatorTest.java | 36 +-
extensions-contrib/thrift-extensions/pom.xml | 30 +-
.../data/input/thrift/ThriftInputFormatTest.java | 24 +-
extensions-contrib/time-min-max/pom.xml | 35 +-
.../TimestampGroupByAggregationTest.java | 59 +-
.../TimestampMinMaxAggregatorFactoryTest.java | 22 +-
.../aggregation/TimestampMinMaxAggregatorTest.java | 45 +-
extensions-contrib/virtual-columns/pom.xml | 20 +-
.../druid/segment/MapVirtualColumnGroupByTest.java | 22 +-
.../druid/segment/MapVirtualColumnTopNTest.java | 55 +-
.../druid/query/filter/BloomDimFilterTest.java | 8 +-
extensions-core/druid-pac4j/pom.xml | 2 +-
extensions-core/kafka-indexing-service/pom.xml | 10 -
.../druid/indexing/kafka/KafkaIndexTaskTest.java | 53 +-
.../indexing/kafka/KafkaRecordSupplierTest.java | 20 +-
.../indexing/kafka/simulate/KafkaResource.java | 19 +-
.../kafka/supervisor/KafkaSupervisorSpecTest.java | 94 +--
extensions-core/kinesis-indexing-service/pom.xml | 6 -
.../indexing/kinesis/KinesisIndexTaskTest.java | 10 -
extensions-core/orc-extensions/pom.xml | 2 +
indexing-service/pom.xml | 10 +
.../indexing/compact/CompactionScheduler.java | 7 +-
.../druid/indexing/overlord/DruidOverlord.java | 12 +-
.../overlord/supervisor/SupervisorManager.java | 45 +-
.../scheduledbatch/ScheduledBatchTaskManager.java | 15 +-
.../ActionBasedPublishedSegmentRetrieverTest.java | 16 +-
.../MultipleFileTaskReportFileWriterTest.java | 17 +-
.../indexing/common/RetryPolicyFactoryTest.java | 8 +-
.../druid/indexing/common/RetryPolicyTest.java | 20 +-
.../common/SingleFileTaskReportFileWriterTest.java | 17 +-
.../apache/druid/indexing/common/TaskLockTest.java | 26 +-
.../common/TaskRealtimeMetricsMonitorTest.java | 52 +-
.../indexing/common/TaskStorageDirTrackerTest.java | 50 +-
.../druid/indexing/common/TaskToolboxTest.java | 55 +-
.../common/actions/LocalTaskActionClientTest.java | 6 +-
.../actions/RemoteTaskActionClientFactoryTest.java | 22 +-
.../common/actions/RemoteTaskActionClientTest.java | 28 +-
.../actions/RetrieveSegmentsActionsTest.java | 22 +-
.../RetrieveUsedSegmentsActionSerdeTest.java | 14 +-
.../actions/SegmentAllocateActionSerdeTest.java | 44 +-
.../common/actions/SegmentAllocateActionTest.java | 122 +--
.../common/actions/SegmentAllocationQueueTest.java | 50 +-
.../SegmentTransactionalInsertActionTest.java | 44 +-
.../SegmentTransactionalReplaceActionTest.java | 18 +-
.../common/actions/SurrogateActionTest.java | 6 +-
.../indexing/common/actions/TaskActionTestKit.java | 17 +-
.../common/actions/TaskActionToolboxTest.java | 6 +-
.../indexing/common/actions/TaskLocksTest.java | 62 +-
.../actions/TimeChunkLockAcquireActionTest.java | 32 +-
.../actions/TimeChunkLockTryAcquireActionTest.java | 28 +-
.../common/actions/UpdateLocationActionTest.java | 8 +-
.../common/actions/UpdateStatusActionTest.java | 6 +-
.../common/config/TaskStorageConfigTest.java | 8 +-
.../stats/DropwizardRowIngestionMetersTest.java | 45 +-
.../indexing/common/task/AbstractTaskTest.java | 76 +-
.../indexing/common/task/ArchiveTaskTest.java | 6 +-
.../task/ClientCompactionTaskQuerySerdeTest.java | 74 +-
...ClientKillUnusedSegmentsTaskQuerySerdeTest.java | 64 +-
.../common/task/CompactionInputSpecTest.java | 25 +-
.../common/task/CompactionTaskParallelRunTest.java | 182 +++--
.../common/task/CompactionTaskRunBase.java | 398 +++++-----
.../indexing/common/task/CompactionTaskTest.java | 331 ++++----
.../common/task/CompactionTuningConfigTest.java | 21 +-
.../indexing/common/task/IndexTaskSerdeTest.java | 43 +-
.../druid/indexing/common/task/IndexTaskTest.java | 435 +++++------
.../indexing/common/task/IndexTaskUtilsTest.java | 31 +-
.../indexing/common/task/IngestionTestBase.java | 36 +-
.../indexing/common/task/InputRowFilterTest.java | 18 +-
.../common/task/KillUnusedSegmentsTaskTest.java | 336 ++++----
.../common/task/MinorCompactionInputSpecTest.java | 26 +-
.../druid/indexing/common/task/MoveTaskTest.java | 6 +-
.../common/task/NativeCompactionRunnerTest.java | 12 +-
.../common/task/NativeCompactionTaskRunTest.java | 12 +-
.../druid/indexing/common/task/NoopTaskTest.java | 6 +-
...ePartitionCachingLocalSegmentAllocatorTest.java | 38 +-
.../indexing/common/task/RestoreTaskTest.java | 6 +-
.../druid/indexing/common/task/ShardSpecsTest.java | 8 +-
.../common/task/SpecificSegmentsSpecTest.java | 6 +-
.../druid/indexing/common/task/TaskSerdeTest.java | 218 +++---
.../druid/indexing/common/task/TaskTest.java | 8 +-
.../AbstractMultiPhaseParallelIndexingTest.java | 4 +-
.../AbstractParallelIndexSupervisorTaskTest.java | 69 +-
.../parallel/DeepStoragePartitionLocationTest.java | 10 +-
.../parallel/DeepStoragePartitionStatTest.java | 10 +-
.../parallel/DeepStorageShuffleClientTest.java | 30 +-
.../parallel/DimensionCardinalityReportTest.java | 58 +-
.../parallel/DimensionDistributionReportTest.java | 6 +-
.../parallel/GenericPartitionLocationTest.java | 10 +-
.../batch/parallel/GenericPartitionStatTest.java | 10 +-
...ashPartitionAdjustingCorePartitionSizeTest.java | 38 +-
...hPartitionCachingLocalSegmentAllocatorTest.java | 18 +-
...ashPartitionMultiPhaseParallelIndexingTest.java | 52 +-
.../batch/parallel/HashPartitionTaskKillTest.java | 38 +-
.../task/batch/parallel/HttpShuffleClientTest.java | 50 +-
.../MultiPhaseParallelIndexingRowStatsTest.java | 12 +-
...ltiPhaseParallelIndexingWithNullColumnTest.java | 44 +-
.../parallel/ParallelIndexPhaseRunnerTest.java | 21 +-
.../ParallelIndexSupervisorTaskKillTest.java | 40 +-
.../ParallelIndexSupervisorTaskResourceTest.java | 79 +-
.../ParallelIndexSupervisorTaskSerdeTest.java | 42 +-
.../parallel/ParallelIndexSupervisorTaskTest.java | 91 +--
.../parallel/ParallelIndexTuningConfigTest.java | 79 +-
.../task/batch/parallel/PartialCompactionTest.java | 42 +-
.../PartialDimensionCardinalityTaskTest.java | 145 ++--
.../PartialDimensionDistributionTaskTest.java | 156 ++--
.../PartialGenericSegmentMergeTaskTest.java | 67 +-
.../PartialHashSegmentGenerateTaskTest.java | 70 +-
.../PartialRangeSegmentGenerateTaskTest.java | 52 +-
.../parallel/PartialSegmentMergeIOConfigTest.java | 14 +-
.../PartialSegmentMergeIngestionSpecTest.java | 17 +-
.../parallel/PerfectRollupWorkerTaskTest.java | 21 +-
.../batch/parallel/PushedSegmentsReportTest.java | 2 +-
...ngePartitionAdjustingCorePartitionSizeTest.java | 36 +-
...ngePartitionMultiPhaseParallelIndexingTest.java | 76 +-
.../batch/parallel/RangePartitionTaskKillTest.java | 38 +-
.../parallel/SegmentAllocationRequestTest.java | 6 +-
.../parallel/SinglePhaseParallelIndexingTest.java | 132 ++--
.../batch/parallel/SinglePhaseSubTaskSpecTest.java | 14 +-
.../task/batch/parallel/TaskMonitorTest.java | 66 +-
.../task/batch/parallel/TombstoneHelperTest.java | 86 +--
.../distribution/ArrayOfStringTuplesSerDeTest.java | 18 +-
.../ArrayOfStringsNullSafeSerdeTest.java | 12 +-
.../distribution/StringSketchMergerTest.java | 30 +-
.../parallel/distribution/StringSketchTest.java | 144 ++--
...efaultIndexTaskInputRowIteratorBuilderTest.java | 42 +-
...xTaskInputRowIteratorBuilderTestingFactory.java | 4 +-
...titionIndexTaskInputRowIteratorBuilderTest.java | 32 +-
.../concurrent/ConcurrentReplaceAndAppendTest.java | 290 +++----
.../ConcurrentReplaceAndStreamingAppendTest.java | 102 +--
.../tasklogs/ConsoleLoggingEnforcementTest.java | 30 +-
.../indexing/common/tasklogs/FileTaskLogsTest.java | 99 ++-
.../tasklogs/SwitchingTaskLogStreamerTest.java | 32 +-
.../compact/CompactionSupervisorSpecTest.java | 60 +-
.../compact/OverlordCompactionSchedulerTest.java | 100 +--
.../druid/indexing/input/DruidInputSourceTest.java | 70 +-
.../input/DruidSegmentInputFormatTest.java | 12 +-
.../indexing/input/DruidSegmentReaderTest.java | 162 ++--
.../indexing/input/GeneratorInputSourceTest.java | 24 +-
.../druid/indexing/input/InputRowSchemasTest.java | 24 +-
.../indexing/input/WindowedSegmentIdTest.java | 2 +-
.../druid/indexing/overlord/http/OverlordTest.java | 7 +-
.../overlord/supervisor/SupervisorManagerTest.java | 5 +-
.../supervisor/SupervisorResourceTest.java | 294 +++----
.../QuartzCronSchedulerConfigTest.java | 57 +-
.../ScheduledBatchStatusTrackerTest.java | 15 +-
.../ScheduledBatchSupervisorSpecTest.java | 54 +-
.../ScheduledBatchSupervisorTest.java | 8 +-
.../ScheduledBatchTaskManagerTest.java | 34 +-
.../UnixCronSchedulerConfigTest.java | 28 +-
.../RecordSupplierInputSourceTest.java | 37 +-
.../SeekableStreamAppenderatorConfigTest.java | 46 +-
.../SeekableStreamEndSequenceNumbersTest.java | 22 +-
...SeekableStreamIndexTaskClientAsyncImplTest.java | 102 ++-
.../SeekableStreamIndexTaskRunnerAuthTest.java | 18 +-
.../SeekableStreamIndexTaskRunnerTest.java | 176 +++--
.../SeekableStreamIndexTaskTestBase.java | 52 +-
.../SeekableStreamSamplerSpecTest.java | 27 +-
.../SeekableStreamStartSequenceNumbersTest.java | 18 +-
.../seekablestream/SequenceMetadataTest.java | 33 +-
.../seekablestream/StreamChunkReaderTest.java | 119 +--
.../supervisor/BoundedStreamConfigTest.java | 44 +-
.../supervisor/OffsetSnapshotTest.java | 48 +-
.../SeekableStreamSupervisorIOConfigTest.java | 150 ++--
...treamSupervisorScaleDuringTaskRolloverTest.java | 34 +-
.../SeekableStreamSupervisorSpecTest.java | 216 +++---
.../SeekableStreamSupervisorStateManagerTest.java | 206 ++---
.../SeekableStreamSupervisorStateTest.java | 858 ++++++++++-----------
.../SeekableStreamSupervisorTestBase.java | 4 +-
.../autoscaler/CostBasedAutoScalerConfigTest.java | 343 ++++----
.../autoscaler/CostBasedAutoScalerMockTest.java | 76 +-
.../autoscaler/CostBasedAutoScalerTest.java | 284 ++++---
.../autoscaler/LagBasedAutoScalerTest.java | 14 +-
.../autoscaler/WeightedCostFunctionTest.java | 177 +++--
.../indexing/worker/TaskAnnouncementTest.java | 20 +-
.../indexing/worker/WorkerTaskManagerTest.java | 195 ++---
.../executor/ExecutorLifecycleConfigTest.java | 6 +-
.../indexing/worker/http/WorkerResourceTest.java | 14 +-
...ocalIntermediaryDataManagerAutoCleanupTest.java | 32 +-
...ocalIntermediaryDataManagerConcurrencyTest.java | 38 +-
...ermediaryDataManagerManualAddAndDeleteTest.java | 98 ++-
.../shuffle/ShuffleDataSegmentPusherTest.java | 83 +-
.../worker/shuffle/ShuffleMetricsTest.java | 64 +-
.../indexing/worker/shuffle/ShuffleModuleTest.java | 12 +-
.../worker/shuffle/ShuffleMonitorTest.java | 8 +-
.../worker/shuffle/ShuffleResourceTest.java | 44 +-
licenses.yaml | 22 +-
.../dart/controller/ControllerMessageListener.java | 2 +-
.../msq/dart/controller/DartWorkerManager.java | 13 +-
.../msq/dart/controller/sql/DartSqlEngine.java | 2 +-
.../druid/msq/dart/guice/DartWorkerModule.java | 7 +-
.../druid/msq/dart/worker/DartWorkerClient.java | 4 +-
.../msq/dart/worker/DartWorkerClientImpl.java | 49 +-
.../dart/controller/http/DartSqlResourceTest.java | 60 ++
.../msq/dart/worker/DartWorkerClientImplTest.java | 124 +++
.../druid/msq/exec/MSQCompactionTaskRunTest.java | 123 ++-
.../org/apache/druid/msq/test/MSQTestBase.java | 1 -
pom.xml | 22 +-
.../collections/bitmap/BitmapIterationTest.java | 148 ++--
.../bitmap/WrappedRoaringBitmapTest.java | 39 +-
.../collections/spatial/ImmutableRTreeTest.java | 76 +-
.../apache/druid/common/guava/FutureUtilsTest.java | 76 +-
.../common/semantic/SemanticCreatorUsageTest.java | 23 +-
.../apache/druid/common/utils/UUIDUtilsTest.java | 14 +-
.../data/input/impl/CombiningInputSourceTest.java | 25 +-
.../druid/data/input/impl/CsvReaderTest.java | 46 +-
.../druid/data/input/impl/DelimitedReaderTest.java | 50 +-
.../druid/data/input/impl/JsonNodeReaderTest.java | 133 ++--
.../druid/data/input/impl/JsonReaderTest.java | 161 ++--
.../data/input/impl/RetryingInputStreamTest.java | 1 +
.../org/apache/druid/data/input/impl/RowsTest.java | 151 ++--
.../druid/guice/ConditionalMultibindTest.java | 48 +-
.../druid/guice/DruidSecondaryModuleTest.java | 61 +-
.../apache/druid/guice/ExtensionsLoaderTest.java | 96 +--
.../apache/druid/guice/JsonConfiguratorTest.java | 99 +--
.../apache/druid/hll/HyperLogLogCollectorTest.java | 252 +++---
.../druid/hll/HyperLogLogSerdeBenchmarkTest.java | 27 +-
.../druid/indexer/report/TaskReportSerdeTest.java | 76 +-
.../java/util/common/CompressionUtilsTest.java | 300 +++----
.../druid/java/util/common/GranularityTest.java | 187 ++---
.../java/util/common/HumanReadableBytesTest.java | 379 +++++----
.../druid/java/util/common/RetryUtilsTest.java | 6 +-
.../druid/java/util/common/StringUtilsTest.java | 221 +++---
.../guava/ParallelMergeCombiningSequenceTest.java | 264 +++----
.../java/util/common/guava/TopNSequenceTest.java | 24 +-
.../druid/java/util/emitter/core/EmitterTest.java | 126 +--
.../emitter/service/ServiceMetricEventTest.java | 82 +-
.../java/util/http/client/FriendlyServersTest.java | 48 +-
.../java/util/http/client/JankyServersTest.java | 48 +-
.../util/http/client/pool/ResourcePoolTest.java | 46 +-
.../ClockDriftSafeMonitorSchedulerTest.java | 24 +-
.../java/util/metrics/OshiSysMonitorTest.java | 248 +++---
.../java/util/metrics/cgroups/CpuAcctTest.java | 59 +-
.../druid/java/util/metrics/cgroups/CpuV2Test.java | 103 +--
.../apache/druid/query/NestedDataTestUtils.java | 356 ++++++++-
.../query/aggregation/AggregationTestHelper.java | 3 +-
.../groupby/GroupByQueryRunnerTestHelper.java | 164 ++++
.../druid/query/groupby/TestGroupByBuffers.java | 2 +-
.../org/apache/druid/segment/CloserExtension.java | 110 +++
.../java/org/apache/druid/segment/TestHelper.java | 88 ++-
.../druid/testing/TemporaryFolderExtension.java | 145 ++++
...aptureRule.java => LoggerCaptureExtension.java} | 41 +-
.../org/apache/druid/timeline/DataSegmentTest.java | 180 ++---
.../VersionedIntervalTimelineSpecificDataTest.java | 78 +-
.../timeline/VersionedIntervalTimelineTest.java | 317 ++++----
.../partition/DimensionRangeShardSpecTest.java | 54 +-
.../partition/DimensionValueSetShardSpecTest.java | 84 +-
.../partition/HashBasedNumberedShardSpecTest.java | 100 +--
.../partition/OvershadowableManagerTest.java | 239 +++---
.../partition/PartitionHolderCompletenessTest.java | 21 +-
.../org/apache/druid/utils/CloseableUtilsTest.java | 93 +--
.../indexing/overlord/LeaderOverlordService.java | 58 ++
.../server/coordinator/DruidCoordinatorTest.java | 20 +-
.../java/org/apache/druid/cli/CliOverlord.java | 7 +
.../druid/server/AsyncQueryForwardingServlet.java | 20 +
.../server/AsyncQueryForwardingServletTest.java | 33 +
.../testing/embedded/EmbeddedServiceClient.java | 7 +-
sql/pom.xml | 22 +-
.../org/apache/druid/sql/SqlQueryPlusTest.java | 6 +-
.../org/apache/druid/sql/SqlStatementTest.java | 8 +-
.../druid/sql/calcite/BaseCalciteQueryTest.java | 94 ++-
.../druid/sql/calcite/CalciteArraysQueryTest.java | 6 +-
.../druid/sql/calcite/CalciteExportTest.java | 41 +-
.../druid/sql/calcite/CalciteIngestionDmlTest.java | 44 +-
.../druid/sql/calcite/CalciteInsertDmlTest.java | 62 +-
.../druid/sql/calcite/CalciteJoinQueryTest.java | 24 +-
.../calcite/CalciteLookupFunctionQueryTest.java | 14 +-
.../calcite/CalciteMultiValueStringQueryTest.java | 7 +-
.../sql/calcite/CalciteNestedDataQueryTest.java | 91 +--
.../sql/calcite/CalciteParameterQueryTest.java | 7 +-
.../apache/druid/sql/calcite/CalciteQueryTest.java | 88 +--
.../druid/sql/calcite/CalciteReplaceDmlTest.java | 11 +-
.../druid/sql/calcite/CalciteSubqueryTest.java | 10 +-
.../druid/sql/calcite/CalciteTableAppendTest.java | 24 +-
.../druid/sql/calcite/CalciteUnionQueryTest.java | 20 +-
.../druid/sql/calcite/CalciteWindowQueryTest.java | 24 +-
.../DecoupledPlanningCalciteJoinQueryTest.java | 2 +-
.../druid/sql/calcite/DrillWindowQueryTest.java | 15 +-
.../druid/sql/calcite/IngestTableFunctionTest.java | 18 +-
.../apache/druid/sql/calcite/NotYetSupported.java | 13 +-
.../apache/druid/sql/calcite/QueryTestRunner.java | 50 +-
...lVectorizedExpressionResultConsistencyTest.java | 49 +-
.../calcite/parser/DruidSqlParserUtilsTest.java | 4 +-
.../BrokerSegmentMetadataCacheConcurrencyTest.java | 36 +-
.../BrokerSegmentMetadataCacheConfigTest.java | 20 +-
.../schema/BrokerSegmentMetadataCacheTest.java | 312 ++++----
.../schema/BrokerSegmentMetadataCacheTestBase.java | 20 +
.../calcite/schema/DruidSchemaNoDataInitTest.java | 4 +-
.../sql/calcite/schema/InformationSchemaTest.java | 41 +-
.../sql/calcite/schema/NamedDruidSchemaTest.java | 6 +-
.../sql/calcite/schema/NamedLookupSchemaTest.java | 6 +-
.../sql/calcite/schema/NamedSystemSchemaTest.java | 10 +-
.../PhysicalDataSourceMetadataFactoryTest.java | 24 +-
.../sql/calcite/schema/RootSchemaProviderTest.java | 12 +-
.../calcite/schema/SystemSchemaFiltersTest.java | 40 +-
.../druid/sql/calcite/schema/SystemSchemaTest.java | 323 ++++----
.../org/apache/druid/sql/http/SqlResourceTest.java | 5 +-
web-console/pom.xml | 4 +-
504 files changed, 14094 insertions(+), 12771 deletions(-)
copy
processing/src/test/java/org/apache/druid/tasklogs/TaskPayloadManagerTest.java
=>
extensions-contrib/druid-deltalake-extensions/src/test/java/org/apache/druid/delta/DeltaAssertions.java
(58%)
create mode 100644
multi-stage-query/src/test/java/org/apache/druid/msq/dart/worker/DartWorkerClientImplTest.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/CloserExtension.java
create mode 100644
processing/src/test/java/org/apache/druid/testing/TemporaryFolderExtension.java
copy
processing/src/test/java/org/apache/druid/testing/junit/{LoggerCaptureRule.java
=> LoggerCaptureExtension.java} (72%)
create mode 100644
server/src/main/java/org/apache/druid/indexing/overlord/LeaderOverlordService.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
