This is an automated email from the ASF dual-hosted git repository.
FrankChen021 pushed a change to branch codex/dependency-check-incremental-cache
in repository https://gitbox.apache.org/repos/asf/druid.git
omit 35d284d8d0c ci: align dependency-check suppression selectors
omit c8ad2256a0c ci: carry dependency-check suppressions
omit f11a12c061f ci: avoid rerunning dependency check in failure message
omit 34e06688ccd ci: report dependency check results for all modules
omit f5760a5493c ci: fix dependency check NVD updates
omit c7be889674b ci: upgrade dependency check and isolate database updates
omit 7977a4ac3bd ci: prefer NVD API secret for dependency check
omit fd6a8dc2809 ci: use repository NVD API secret
omit 3e438b467a7 ci: report dependency-check cache match
omit 54bc59afc82 ci: avoid pull request scoped dependency caches
omit 32629a39935 ci: defer dependency check failure and update scanner
omit 255c0a218d9 ci: enable incremental dependency-check updates
add ed8efd5afdb fix: In coordinator duty loop - use an immutable snapshot
of retention rules per run cycle (#20063)
add b2e09009054 fix: safer sizing for partial segment metadata header,
simplify bootstrap (#20105)
add b4882aa503a perf: Descending vector cursors. (#19947)
add 20d733e735b feat: allow non-sealed schemas for MSQ when using base
table spec (#19845)
add 9b2c13c0235 Emit taskStatus on task/run/time from the statsd and
prometheus emitters (#20122)
add cf75e06d4f9 fix: Prevent a single unhealthy historical from stalling
all segment loading and balancing. (#19950)
add 6474032ba78 feat: Add mergeBuffer/maxSpillProximity metric for groupBy
spill diagnosis (#19627)
add 3ecf177431a feat: User-aware SchemaProviders for SQL. (#20075)
add 31ffc8add3c build(deps): bump aws.sdk.v2.version from 2.53.3 to 2.54.2
(#20130)
add 7d74dbbf5a3 build(deps): bump graaljs.version from 25.1.3 to 25.2.4
(#20131)
add c104a34f37c build(deps-dev): bump commons-codec:commons-codec from
1.20.0 to 1.22.1 (#20133)
add a75bf4751b7 build(deps-dev): bump org.objenesis:objenesis from 3.5 to
3.6 (#20134)
add b741a6c3bd2 build(deps): bump org.codehaus.plexus:plexus-utils from
3.6.1 to 4.1.0 (#20135)
add f7d2fd92dfa build(deps): bump
org.apache.maven.plugins:maven-compiler-plugin (#20138)
add 927d661c334 build(deps): bump javax.annotation:javax.annotation-api
(#20139)
add c857939154d build(deps-dev): bump
com.google.api.grpc:proto-google-common-protos (#20140)
add 772c3deca8d build(deps): bump kr.motd.maven:os-maven-plugin (#20141)
add 8ab13129f82 build(deps): bump org.apache.commons:commons-pool2 from
2.13.0 to 2.13.1 (#20142)
add 320352b00a8 build(deps-dev): bump com.github.os72:protobuf-dynamic
(#20143)
add d55c13c2453 build(deps-dev): bump
com.google.cloud:google-cloud-storage from 2.29.1 to 2.71.0 (#20144)
add 401b2ffece9 build(deps): bump
io.github.resilience4j:resilience4j-bulkhead from 1.3.1 to 2.4.0 (#20145)
add 5f40d157480 build(deps): bump guava.version from 33.6.0-jre to
33.7.1-jre (#20146)
add 3e5e0b92bfb build(deps): bump io.projectreactor:reactor-core from
3.7.19 to 3.8.7 (#20147)
add f609d0a573d build(deps): bump org.apache:apache from 25 to 39 (#20148)
add 1ed7baae5cb fix: more chill abandoned partial loads and safer deferred
eviction of weak held entries (#20073)
add 640609453e5 feat: For partial loads, hook into existing strategic
assigner code to better distribute partial load requests (#20155)
add 4cd3036560d build(deps): bump com.netflix.spectator:spectator-api
(#20153)
add ba8da866530 build(deps): bump com.ibm.icu:icu4j from 77.1 to 78.3
(#20154)
add d9910ae931a don't compile the reactor twice in the strict-compilation
CI job (#20175)
add 7c367db7ded fix: separate storage location accounting for internal
cache holds (#20150)
add 35458dcf87b build(deps): bump org.postgresql:postgresql from 42.7.12
to 42.7.13 (#20172)
add f9096e9a0c8 build(deps): bump nl.jqno.equalsverifier:equalsverifier
(#20171)
add e72478afc95 build(deps-dev): bump
org.glassfish.grizzly:grizzly-http-server from 2.2.16 to 5.0.2 (#20170)
add 1e17525ab0d build(deps): bump
org.apache.maven.plugins:maven-resources-plugin from 3.2.0 to 3.5.0 (#20169)
add ab632beed0c build(deps): bump
jakarta.activation:jakarta.activation-api from 1.2.2 to 2.1.4 (#20167)
add 526b27c8dcf build(deps): bump jakarta.xml.bind:jakarta.xml.bind-api
from 2.3.3 to 4.0.5 (#20166)
add 520ae68e1d4 build(deps): bump graaljs.version from 25.2.4 to 25.3.4.1
(#20165)
add c887ef5ad4b build(deps): bump io.grpc:grpc-context from 1.82.2 to
1.83.1 (#20163)
add b43041bffca build(deps-dev): bump
org.openrewrite.maven:rewrite-maven-plugin (#20161)
add 45464960e94 build(deps): bump com.nimbusds:oauth2-oidc-sdk from 10.8
to 11.38.2 (#20160)
add 2994a134f86 build(deps-dev): bump
io.github.git-commit-id:git-commit-id-maven-plugin from 9.0.1 to 10.0.0 (#20158)
add 8c05f05adbe build(deps-dev): bump org.cyclonedx:cyclonedx-maven-plugin
(#20156)
add 481e8fbc79f fix: validate numBytes in
CompressedVSizeColumnarIntsSupplier (#20174)
add 9e17b1c48a1 fix: cache entries use self hold to avoid eviction while
mounting, and other fixes (#20182)
add d9f019a3143 build(deps): bump org.owasp:dependency-check-maven from
12.2.0 to 13.0.0 (#20179)
add 1de4ba0f92f build(deps): bump com.fasterxml.woodstox:woodstox-core
from 6.4.0 to 7.2.2 (#20178)
add 0a1ae6ec7dd build(deps-dev): bump
com.google.auth:google-auth-library-credentials (#20177)
add 2c04f16f99e build(deps): bump aws.sdk.v2.version from 2.54.2 to 2.54.3
(#20176)
add b65818144da build(deps): bump protobuf.version from 4.35.1 to 4.36.0
(#20164)
add 9318bbee1a2 perf: Faster advanceIfNeeded for Roaring iterators.
(#20129)
add fbf472cb677 build(deps): bump org.mariadb.jdbc:mariadb-java-client
from 2.7.3 to 3.5.10 (#20036)
add 11a5acd3b8e build(deps): bump org.asynchttpclient:async-http-client
from 3.0.11 to 3.0.13 (#20184)
add b35000f3844 build(deps): bump aws.sdk.v2.version from 2.54.3 to 2.54.4
(#20185)
add 543fb4c2ffa build(deps-dev): bump org.bouncycastle:bcpkix-jdk18on from
1.84 to 1.85 (#20186)
add 66e02257fdb build(deps): bump org.openrewrite.recipe:rewrite-jackson
(#20187)
add 943106095be build(deps-dev): bump
com.github.spotbugs:spotbugs-maven-plugin (#20188)
add 2e9f6e79bcd build(deps): bump org.codehaus.woodstox:stax2-api from
4.2.2 to 4.3.0 (#20189)
add 487a3d8886d build(deps): bump delta-kernel.version from 4.3.1 to 4.4.0
(#20190)
add 05c419c69c5 build(deps): bump com.rabbitmq:stream-client from 0.15.0
to 1.11.0 (#20191)
add 37cc817de76 build(deps-dev): bump
io.github.ascopes:protobuf-maven-plugin from 3.10.2 to 5.1.8 (#20192)
add daa49cbbcbb build(deps): bump org.codehaus.plexus:plexus-utils from
3.6.1 to 4.1.0 (#20193)
add 34e2bd03347 build(deps-dev): bump
com.google.api.grpc:proto-google-common-protos (#20194)
add 677dee66b78 build(deps): bump
io.opentelemetry.instrumentation:opentelemetry-instrumentation-bom-alpha
(#20195)
add ba44125e1a1 build(deps): bump com.google.api:gax from 2.83.0 to 2.84.0
(#20196)
add 9068d2abdf6 fix: address CodeQL concurrency warnings (#19827)
add 593191fc793 fix: secure temporary files and resource lookups (#19822)
add 4a8868eb52f feat: `druid.s3.enableLegacyMd5` property added (#20055)
add ec7952b0e84 feat: druid-opa-authorizer extension for Open Policy Agent
authorization (#19670)
add 3885a95fc0d feat: Add reverse group lookup for LDAP servers that do
not return memberOf (#19432)
add 760f3cdfae3 fix: avoid sleeping while holding lifecycle locks (#19810)
add c6fcf4325b6 feat: warn when hash/range ingest publishes oversized
segments (#20173)
add c529ecef840 feat: Extend FilterSegmentPruner to prune on
ClusterGroupTuples (#20149)
add 1bbb062442e test: migrate ExecutorLifecycleTest to JUnit 5 (#20223)
add cf2046495ba build(deps-dev): bump
com.google.cloud:google-cloud-storage (#20220)
add 760e453cb9a build(deps): bump nl.jqno.equalsverifier:equalsverifier
(#20219)
add 75d038e9ef0 build(deps): bump org.easymock:easymock from 5.6.0 to
5.7.0 (#20217)
add 035b9a2a4a6 build(deps-dev): bump com.github.fppt:jedis-mock from
1.1.17 to 1.1.18 (#20216)
add f9e9ae9e170 build(deps-dev): bump
net.nicoulaj.maven.plugins:checksum-maven-plugin (#20214)
add b0019d3e1ea build(deps): bump org.jacoco:jacoco-maven-plugin from
0.8.14 to 0.8.15 (#20211)
add db7983e7dbc build(deps): bump oshi.version from 7.5.0 to 7.6.0 (#20210)
add bfa89c4e1e1 build(deps): bump
com.google.auto.value:auto-value-annotations (#20209)
add 1f82d21700b build(deps): bump org.yaml:snakeyaml from 2.5 to 2.6
(#20207)
add 0eaf3ab04a8 build(deps): bump dropwizard.metrics.version from 4.2.39
to 4.2.40 (#20206)
add 23d0ebcad5f build(deps): bump org.junit:junit-bom from 5.14.3 to 6.1.3
(#20205)
add ed63dfd0444 build(deps): bump org.openrewrite.recipe:rewrite-apache
(#20203)
add 14ad79f1f62 build(deps): bump aws.sdk.v2.version from 2.54.4 to 2.54.7
(#20201)
add d8650f806b5 build(deps): bump org.codehaus.mojo:exec-maven-plugin
(#20229)
add 2e3ca051bb6 build(deps): bump net.thisptr:jackson-jq from 1.6.2 to
1.6.3 (#20227)
add ba84c74727d fix: Race between run and cancellation in
FrameProcessorExecutor. (#19006)
add 2bf1643cddc fix: Apply cloneQueryMode prior to choosing server type.
(#20244)
add f8faf5fad8c build(deps-dev): bump fast-uri from 3.1.5 to 3.1.7 in
/web-console (#20242)
add 15d6f01c552 build(deps): bump org.yaml:snakeyaml from 2.6 to 2.7
(#20241)
add 7dde97b1c16 build(deps): bump
org.apache.maven.plugins:maven-compiler-plugin (#20239)
add 68f90b259d0 build(deps): bump fast-uri from 3.1.5 to 3.1.7 in /website
(#20238)
add d3e6e4c25fa build(deps-dev): bump @humanfs/node in /web-console
(#20237)
add fb1b5011ebc build(deps): bump browserslist from 4.28.2 to 4.28.8 in
/website (#20232)
add a5062fd8f14 build(deps): bump postcss-selector-parser in /web-console
(#20231)
add 6c9838aaa83 build(deps): bump postcss-selector-parser in /website
(#20225)
add 195d1e1b847 fix: validate blockSize and numBlocks in
CompressedBlockReader (#20243)
add cad5e44f155 feat: Support PostgreSQL export for export-metadata
(#19698)
add 58ccdfa1dba feat: Directly produce Resource in NamedSchema. (#20254)
add 89d0e9b5e84 feat: Pluggable DataSourcePlanners for MSQ. (#20253)
add 7109f88f28a build(deps-dev): bump browserslist from 4.24.0 to 4.28.8
in /web-console (#20252)
add c2013c62c30 build(deps-dev): bump com.google.guava:guava (#20251)
add 45b4f69a6f8 build(deps): bump protobuf.version from 4.36.0 to 4.36.1
(#20250)
add 380b92259e2 build(deps): bump
org.apache.maven.plugins:maven-surefire-plugin (#20249)
add 34081ce64fe build(deps): bump aws.sdk.v2.version from 2.54.7 to 2.54.8
(#20248)
add 3a484baf10e build(deps): bump org.checkerframework:checker-qual from
4.2.2 to 4.2.3 (#20266)
add 0d6643bc701 build(deps): bump io.grpc:grpc-bom from 1.83.1 to 1.84.0
(#20265)
add 62a75f12c49 build(deps): bump io.grpc:grpc-netty-shaded from 1.83.1 to
1.84.0 (#20263)
add df720affe30 build(deps): bump oshi.version from 7.6.0 to 7.6.1 (#20261)
add 17e57f9e37f build(deps-dev): bump
io.github.git-commit-id:git-commit-id-maven-plugin (#20260)
add 9b967a613ef build(deps): bump io.grpc:grpc-api from 1.83.1 to 1.84.0
(#20259)
add be3e96ee561 build(deps): bump io.grpc:grpc-context from 1.83.1 to
1.84.0 (#20257)
add e9db64b6e97 build(deps): bump aws.sdk.v2.version from 2.54.8 to
2.54.10 (#20256)
add 9b90983fd29 build(deps): bump parquet.version from 1.18.0 to 1.18.1
(#20258)
add 8cbcc40d215 build(deps): bump js-yaml from 3.14.2 to 3.15.2 in
/website (#20269)
add df133e4687c test: fix flaky test EmbeddedDartReportApiTest (#19905)
add 7d00d197a64 fix(processing): finalize SuperSorter progress before
completion (#20054)
add 0741bb68620 perf(test): cut high-cost CI test latency while preserving
coverage (#20127)
add a8ea1a4f9ed refactor!: remove deprecated SysMonitor (#20200)
add 0a0196c51b4 ci: reduce CI duration from 1h15m to 43m (#20270)
add f37486d51b6 feat: Add lag/idle plot simulator for cost-based
autoscaler (#19687)
add 33f7f778dfc ci: Fix SupervisorManagerTest (#20294)
add 5b593c5a8b7 build(deps-dev): bump
com.google.auth:google-auth-library-credentials (#20289)
add 9e47913b490 build(deps): bump com.squareup.okio:okio-jvm from 3.18.1
to 3.18.2 (#20288)
add 5653fa60991 build(deps): bump bytebuddy.version from 1.18.12 to
1.18.13 (#20285)
add b7f3cb10d10 build(deps): bump net.thisptr:jackson-jq from 1.6.3 to
1.6.4 (#20283)
add 514b6d1f624 build(deps): bump org.roaringbitmap:RoaringBitmap from
1.6.20 to 1.6.21 (#20282)
add 5f0b837695f build(deps-dev): bump
com.google.api.grpc:proto-google-common-protos (#20281)
add cc8b58642d4 build(deps): bump slf4j.version from 2.0.18 to 2.0.19
(#20279)
add d1b99ecc204 minor: Prioritize load of unavailable segment (#20245)
add 35e9e436a7f feat: Update to Calcite 1.42.0. (#19976)
add 617d63d4845 perf(test): Reduce PartialCompactionTest run time from 42s
to 7s (#20306)
add 165d3860f73 build(deps): bump svgo from 3.3.4 to 3.3.5 in /website
(#20304)
add 621cff36224 build(deps): bump joi from 17.13.3 to 17.13.7 in /website
(#20303)
add 59d91dbf114 build(deps-dev): bump
com.github.spotbugs:spotbugs-maven-plugin (#20302)
add dbffc6c701c build(deps): bump colord from 2.9.3 to 2.10.0 in /website
(#20301)
add ef51f7923c0 build(deps): bump @swc/html from 1.15.40 to 1.16.2 in
/website (#20300)
add ae02f0e40e8 build(deps): bump com.google.api:gax from 2.84.0 to 2.85.0
(#20287)
add 46d24e0b8c6 build(deps): bump
software.amazon.kinesis:amazon-kinesis-client from 3.5.1 to 3.5.2 (#20286)
add ace912daf55 build(deps-dev): bump
com.google.cloud:google-cloud-storage from 2.72.0 to 2.73.0 (#20284)
add ddba5f9b70e build(deps): bump com.squareup.okio:okio from 3.18.1 to
3.18.2 (#20280)
add 8a7afbfa853 build(deps-dev): bump com.google.cloud:google-cloud-core
from 2.73.0 to 2.75.0 (#20278)
add c7c73625a5b build(deps): bump jetty.version from 12.1.12 to 12.1.13
(#20277)
add 8f402c89566 build(deps): bump fabric8.version from 7.8.0 to 7.9.0
(#20276)
add 91fe02f0f25 build(deps): bump aws.sdk.v2.version from 2.54.10 to
2.54.13 (#20274)
add 3985d927a66 test: enable compact object headers across test JVMs
(#20271)
add 8ff36f7ef89 fix: safely publish granularity interval lookups (#20292)
add 61ed0a389d6 fix: use portable printf for Docker runtime properties
(#20272)
add 8d9545ea585 feat: Define clone sync criteria in
CoordinatorDynamicConfig (#20247)
add 1f68c5e1687 fix: harden arithmetic and bounds checks (#19818)
add 9a17b007ec1 fix: reject newlines in redirect locations (#19812)
add 32c3dc4a85e fix: Treat empty string in hadoop.auth cookie as no cookie
(#20234)
add 83d5f16b976 perf(test): reduce MergingRowIteratorTest from 24s to 5s
(#20305)
add 5e71056845b feat(server): add response identity headers (#20268)
add fb8bb5fafd0 docs: Add documentation for fastIntervalSearch config
(#19861)
add e5208b3fd28 build(deps): bump com.github.wnameless.json:json-flattener
(#20309)
add 26301598f7e feat: Refactor names for tier segment cache usage to help
with observability and monitoring (#20199)
add 89e0c91076a fix(sql): classify invalid timestamp constants (#20328)
add bbb161c37dd feat: partial load rules assignment prefer in-place reload
over fresh load (#20267)
add 45128436a9a fix: SettableAsyncResource fire callbacks if closed before
set (#20074)
add 51e31a68c26 refactor: migrate Druid HTTP client from Netty 3 to 4
(#19567)
add 07c2975099e build(deps): bump org.jetbrains.kotlin:kotlin-stdlib from
2.4.10 to 2.4.20 (#20325)
add cc6b29aad5b build(deps): bump net.thisptr:jackson-jq from 1.6.4 to
1.6.5 (#20323)
add bba74f6cb28 ci: switch MinIO test image from Docker Hub to Quay
(#20331)
add d480d66e7fe fix: validate size in FixedIndexed header (#20315)
add 6a8cc4a06b5 fix: update PullDependencies to exclude netty-4 jars
(#20332)
add 80a570ae151 build(deps): bump nanoid from 3.3.16 to 3.3.19 in /website
(#20334)
add 4395ef34647 build(deps): bump aws.sdk.v2.version from 2.54.13 to
2.54.14 (#20330)
add 4dc0437e0f3 test: use a long taskDuration for bounded Kafka supervisor
tests (#20311)
add 76ddcf297e4 perf(test): Reduce compaction tests 12min and Re-sharding
test cases to reduce 6min (#20307)
add 997a2a95683 ci: cut Docker test job from 40m to 25m by building a lean
distribution (#20297)
add 97fcd37ce72 ci: do not fail unit test jobs when the JFR profiler agent
cannot be downloaded (#20318)
add e3f06eac3ec fix: per-segment timeout accounting bug (#20290)
add 899f765a39a minor: remove AsyncResources#fromFutureCloseable (#20356)
add 0eeda00c7d8 build(deps-dev): bump org.bouncycastle:bcpkix-jdk18on from
1.85 to 1.86 (#20352)
add 52c688b7cea build(deps-dev): bump
org.codehaus.mojo:animal-sniffer-maven-plugin (#20350)
add 4d6d6140c30 build(deps): bump org.bitbucket.b_c:jose4j from 0.9.6 to
0.9.7 (#20349)
add 25f56955e80 build(deps): bump org.roaringbitmap:RoaringBitmap from
1.6.21 to 1.6.23 (#20348)
add 3958b1fac49 build(deps): bump com.netflix.spectator:spectator-api
(#20347)
add 0f7071077fc build(deps): bump org.codehaus.mojo:exec-maven-plugin
(#20346)
add 8aa0c211a9d build(deps): bump
org.codehaus.mojo:build-helper-maven-plugin (#20345)
add bf77096e67a build(deps-dev): bump org.bouncycastle:bcprov-jdk18on
(#20344)
add ccca0bd7fa6 build(deps): bump opentelemetry.version from 1.65.0 to
1.66.0 (#20343)
add 480f9a85ab9 build(deps): bump netty4.version from 4.2.17.Final to
4.2.18.Final (#20342)
add ee6b0439d02 build(deps): bump aws.sdk.v2.version from 2.54.14 to
2.54.17 (#20340)
add b555785b40e fix(sql): honor Statement.setMaxRows in the Avatica JDBC
server (#19941)
add 5b1bcc11782 test: fix flaky KubernetesTaskRunnerTest start tests
(#20316)
add 9f5363cc5f3 feat: ddl statements + catalog (#19830)
add 0020a4c564d build(deps): bump at.yawk.lz4:lz4-java from 1.11.2 to
1.11.3 (#20359)
add 95f3747a080 build(deps): bump
org.apache.maven.plugins:maven-install-plugin (#20358)
add 2fed7ca11d9 build(deps-dev): bump
org.apache.maven.plugins:maven-deploy-plugin (#20357)
add 3935ad1ac36 ci: enable incremental dependency-check updates
add 6aa0e98d850 ci: defer dependency check failure and update scanner
add ce484891a23 ci: avoid pull request scoped dependency caches
add 569aa8ad323 ci: report dependency-check cache match
add b83927e718e ci: use repository NVD API secret
add 13ab2630c9c ci: prefer NVD API secret for dependency check
add 2bedd49c1c8 ci: upgrade dependency check and isolate database updates
add e47a16256a4 ci: fix dependency check NVD updates
add 34e7f1b9d2c ci: report dependency check results for all modules
add 55b4a0cd90a ci: avoid rerunning dependency check in failure message
add 8c02aed8edd ci: carry dependency-check suppressions
add ca006680fd3 ci: align dependency-check suppression selectors
add 62e4be3892c ci: sync dependency-check suppressions
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 (35d284d8d0c)
\
N -- N -- N refs/heads/codex/dependency-check-incremental-cache
(62e4be3892c)
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:
.dockerignore | 6 +
.github/scripts/openrewrite.sh | 1 -
.github/scripts/packaging-check.sh | 16 +-
.github/scripts/run_docker-tests | 8 +-
.github/scripts/setup_test_profiling_env.sh | 48 +-
.github/scripts/static-checks-maven.sh | 12 +-
.github/scripts/strict-compilation.sh | 2 +-
.github/scripts/test_balancing_calc | 5 +-
.github/workflows/ci.yml | 8 +-
.github/workflows/codeql.yml | 10 +-
.github/workflows/docker-tests.yml | 38 +-
.../unit-and-integration-tests-unified.yml | 1 -
.github/workflows/worker.yml | 2 +-
benchmarks/pom.xml | 10 +-
.../benchmark/FrontCodedIndexedBenchmark.java | 6 +-
.../druid/benchmark/GenericIndexedBenchmark.java | 2 +-
.../benchmark/indexing/IndexMergeBenchmark.java | 6 +-
.../druid/benchmark/query/InPlanningBenchmark.java | 12 +-
.../druid/benchmark/query/SqlBaseBenchmark.java | 8 +-
.../benchmark/query/SqlVsNativeBenchmark.java | 12 +-
.../druid/benchmark/query/TimeseriesBenchmark.java | 166 +--
.../calcite/schema/SysSegmentsTableBenchmark.java | 17 +-
.../apache/druid/common/aws/AWSClientConfig.java | 10 +
.../druid/common/aws/AWSClientConfigTest.java | 12 +
dev/upgrade-calcite-parser | 4 +-
distribution/bin/check-licenses.py | 12 +
.../bin/generate-license-dependency-reports.py | 4 +-
distribution/docker/Dockerfile.mariadb | 6 +-
distribution/docker/druid.sh | 6 +-
distribution/docker/peon.sh | 6 +-
distribution/pom.xml | 4 +-
docs/api-reference/api-reference.md | 16 +
docs/api-reference/dynamic-configuration-api.md | 7 +-
docs/configuration/extensions.md | 1 +
docs/configuration/index.md | 33 +-
docs/development/build.md | 2 +-
.../extensions-contrib/druid-opa-authorizer.md | 189 ++++
docs/development/extensions-core/catalog.md | 215 +++-
.../extensions-core/druid-basic-security.md | 12 +
docs/development/extensions-core/mysql.md | 10 +-
docs/development/extensions-core/s3.md | 1 +
docs/development/modules.md | 2 +-
docs/multi-stage-query/security.md | 6 +-
docs/operations/auth-ldap.md | 23 +-
docs/operations/deep-storage-migration.md | 3 +-
docs/operations/export-metadata.md | 148 ++-
docs/operations/metadata-migration.md | 7 +-
docs/operations/metrics.md | 57 +-
docs/querying/query-context-reference.md | 11 +-
embedded-tests/pom.xml | 32 +-
.../auth/AbstractAuthConfigurationTest.java | 49 +-
.../embedded/auth/BasicAuthConfigurationTest.java | 4 +-
.../embedded/auth/BasicAuthIndexingTest.java | 2 +-
.../auth/BasicAuthLdapConfigurationTest.java | 4 +-
.../auth/BasicAuthLdapReverseGroupLookupTest.java | 42 +-
.../embedded/auth/EmbeddedBasicAuthResource.java | 4 +-
.../druid/testing/embedded/auth/HttpUtil.java | 4 +-
.../auth/LdapReverseGroupLookupAuthResource.java | 47 +
.../testing/embedded/auth/SecurityClient.java | 2 +-
.../druid/testing/embedded/auth/TLSTest.java | 4 +-
.../embedded/catalog/CatalogDdlAndIngestTest.java | 531 +++++++++
.../embedded/catalog/TestCatalogClient.java | 2 +-
.../embedded/compact/AutoCompactionTest.java | 5 +-
.../compact/CompactionResourceTestClient.java | 2 +-
.../IngestionBackwardCompatibilityDockerTest.java | 2 +-
.../embedded/indexer/AbstractITBatchIndexTest.java | 2 +-
.../indexing/KafkaBoundedSupervisorTest.java | 17 +
.../embedded/indexing/KafkaClusterMetricsTest.java | 1 +
.../indexing/StreamIndexFaultToleranceTest.java | 2 +-
.../CostBasedAutoScalerIntegrationTest.java | 6 +-
.../testing/embedded/kinesis/KinesisResource.java | 50 +-
.../embedded/minio/MinIOStorageResource.java | 4 +-
.../embedded/msq/EmbeddedDartReportApiTest.java | 44 +-
.../testing/embedded/msq/EmbeddedMSQApis.java | 2 +-
.../embedded/msq/MSQWorkerFaultToleranceTest.java | 45 +-
.../opa/OpaBasicAuthConfigurationDockerTest.java | 148 +++
.../testing/embedded/opa/OpaBasicAuthResource.java | 107 ++
.../opa/OpaLdapAuthConfigurationDockerTest.java | 139 +++
.../testing/embedded/opa/OpaLdapAuthResource.java | 131 +++
.../testing/embedded/query/JdbcQueryTest.java | 4 +-
.../testing/embedded/query/MsqTaskSubmitTest.java | 6 +-
.../testing/embedded/query/QueryTestBase.java | 4 +-
.../embedded/query/QueryVirtualStorageTest.java | 8 +-
.../testing/embedded/query/SqlQueryCancelTest.java | 10 +-
.../query/SqlQueryHttpRequestHeadersTest.java | 6 +-
.../schema/SystemServerPropertiesTableTest.java | 2 +-
.../embedded/server/CoordinatorPauseTest.java | 2 +-
.../testing/embedded/server/FaultyClusterTest.java | 2 +-
.../embedded/server/HighAvailabilityTest.java | 4 +-
.../server/KillSupervisorsCustomDutyTest.java | 2 +-
.../server/ResponseIdentityHeaderTest.java | 259 +++++
.../src/test/resources/ldap-configs/bootstrap.ldif | 8 +-
.../src/test/resources/opa-configs/druid.json | 41 +
.../src/test/resources/opa-configs/druid.rego | 20 +
.../druid/storage/aliyun/OssDataSegmentPusher.java | 39 +-
.../druid/storage/aliyun/OssTaskLogsTest.java | 3 +-
...ListBasedDruidToTimelineEventConverterTest.java | 26 +-
.../cassandra/CassandraDataSegmentPusher.java | 56 +-
extensions-contrib/cloudfiles-extensions/pom.xml | 2 +-
.../cloudfiles/CloudFilesDataSegmentPusher.java | 4 +-
...pressedBigDecimalAggregatorGroupByTestBase.java | 28 +-
...ssedBigDecimalAggregatorTimeseriesTestBase.java | 47 +-
.../druid-deltalake-extensions/pom.xml | 2 +-
.../druid-iceberg-extensions/pom.xml | 16 +-
extensions-contrib/druid-opa-authorizer/README.md | 20 +
.../druid-opa-authorizer/example/druid.json | 79 ++
.../druid-opa-authorizer/example/druid.rego | 54 +
.../example/ldap/bootstrap.ldif | 91 ++
.../druid-opa-authorizer/example/ldap/run-ldap.sh | 45 +-
.../example/setup/alice_pass.json | 3 +
.../example/setup/bob_pass.json | 3 +
.../example/setup/christy_pass.json | 3 +
.../example/setup/dylan_pass.json | 3 +
.../example/setup/eve_pass.json | 3 +
.../druid-opa-authorizer/example/setup/setup.sh | 21 +-
.../pom.xml | 118 +-
.../apache/druid/security/opa/OpaAuthorizer.java | 259 +++++
.../apache/druid/security/opa/OpaDruidModule.java | 32 +-
.../druid/security/opa/opatypes/OpaInput.java | 48 +-
.../druid/security/opa/opatypes/OpaMessage.java | 42 +-
.../druid/security/opa/opatypes/OpaResource.java | 31 +-
.../druid/security/opa/opatypes/OpaResponse.java | 40 +-
.../org.apache.druid.initialization.DruidModule | 7 +-
.../druid/security/opa/OpaAuthorizerTest.java | 270 +++++
.../security/opa/opatypes/OpaMessageTest.java | 57 +
.../security/opa/opatypes/OpaResponseTest.java | 68 ++
extensions-contrib/druid-ranger-security/pom.xml | 7 +-
.../overlord/autoscaling/gce/GceAutoScaler.java | 10 +-
.../graphite/WhiteListBasedConverterTest.java | 25 +-
extensions-contrib/grpc-query/pom.xml | 6 +-
.../java/org/apache/druid/grpc/BasicAuthTest.java | 10 +-
.../movingaverage/MovingAverageQueryTest.java | 10 +-
extensions-contrib/opentelemetry-emitter/pom.xml | 8 +-
.../src/main/resources/defaultMetrics.json | 12 +-
.../druid/emitter/prometheus/MetricsTest.java | 28 +
.../emitter/prometheus/PrometheusEmitterTest.java | 6 +-
.../rabbit-stream-indexing-service/pom.xml | 12 +-
extensions-contrib/spectator-histogram/pom.xml | 2 +-
.../histogram/SpectatorHistogramTest.java | 14 +-
.../main/resources/defaultMetricDimensions.json | 7 +-
.../emitter/statsd/DimensionConverterTest.java | 38 +
.../storage/azure/AzureDataSegmentPusher.java | 3 +-
extensions-core/druid-basic-security/pom.xml | 2 +-
.../druid/security/basic/BasicAuthLDAPConfig.java | 65 ++
.../druid/security/basic/CommonCacheNotifier.java | 8 +-
...natorPollingBasicAuthenticatorCacheManager.java | 2 +-
.../validator/LDAPCredentialsValidator.java | 84 +-
...rdinatorPollingBasicAuthorizerCacheManager.java | 4 +-
.../validator/LDAPCredentialsValidatorTest.java | 230 +++-
...rPollingBasicAuthenticatorCacheManagerTest.java | 26 +-
...atorPollingBasicAuthorizerCacheManagerTest.java | 77 +-
extensions-core/druid-catalog/pom.xml | 2 +-
.../druid/catalog/guice/CatalogClientModule.java | 8 +
.../apache/druid/catalog/http/CatalogResource.java | 51 +-
.../druid/catalog/http/TableEditRequest.java | 127 ++-
.../org/apache/druid/catalog/http/TableEditor.java | 259 ++++-
.../catalog/storage/sql/SQLCatalogManager.java | 214 ++--
.../druid/catalog/sync/CachedMetadataCatalog.java | 41 +
.../apache/druid/catalog/sync/CatalogClient.java | 57 +-
.../druid/catalog/sync/CatalogSqlTableWriter.java | 212 ++++
.../druid/catalog/sync/RestUpdateSender.java | 4 +-
.../apache/druid/catalog/storage/CatalogTests.java | 3 +-
.../druid/catalog/storage/TableManagerTest.java | 80 ++
.../druid/catalog/sync/CacheNotifierTest.java | 2 +-
.../druid/catalog/sync/CatalogCacheTest.java | 42 +
.../server/http/catalog/CatalogResourceTest.java | 81 +-
.../druid/server/http/catalog/EditorTest.java | 301 ++++++
extensions-core/druid-kerberos/pom.xml | 12 +-
.../security/kerberos/KerberosAuthenticator.java | 41 +-
.../security/kerberos/KerberosHttpClient.java | 2 +-
.../security/kerberos/ResponseCookieHandler.java | 8 +-
.../RetryIfUnauthorizedResponseHandler.java | 21 +-
.../kerberos/KerberosAuthenticatorTest.java | 344 +++++-
extensions-core/druid-pac4j/pom.xml | 2 +-
.../druid/security/pac4j/JwtAuthenticatorTest.java | 14 +-
extensions-core/google-extensions/pom.xml | 8 +-
.../storage/google/GoogleDataSegmentPusher.java | 3 +-
.../google/GoogleCloudStorageInputSourceTest.java | 4 +-
.../HdfsFileTimestampVersionFinderTest.java | 9 +-
.../storage/hdfs/HdfsDataSegmentPullerTest.java | 9 +-
extensions-core/kafka-indexing-service/pom.xml | 6 -
.../druid/indexing/kafka/KafkaIndexTaskTest.java | 2 +-
.../indexing/kafka/KafkaRecordSupplierTest.java | 42 +-
.../kafka/supervisor/KafkaSupervisorTest.java | 2 +-
extensions-core/kinesis-indexing-service/pom.xml | 2 +-
.../indexing/kinesis/KinesisIndexTaskTest.java | 2 +-
.../kubernetes-overlord-extensions/pom.xml | 5 +-
.../k8s/overlord/KubernetesTaskRunnerTest.java | 60 +-
.../OffHeapNamespaceExtractionCacheManager.java | 31 +-
.../apache/druid/data/input/MapPopulatorTest.java | 2 +-
.../metadata/storage/mysql/MySQLConnector.java | 12 +
.../MySQLInputSourceDatabaseConnectorTest.java | 22 +
.../metadata/storage/mysql/MySQLConnectorTest.java | 36 +-
extensions-core/parquet-extensions/pom.xml | 5 +
.../storage/postgresql/PostgreSQLConnector.java | 11 +
extensions-core/protobuf-extensions/pom.xml | 10 +-
.../druid/storage/s3/S3DataSegmentPusher.java | 39 +-
.../java/org/apache/druid/storage/s3/S3Utils.java | 25 +
.../storage/s3/ServerSideEncryptingAmazonS3.java | 1 +
.../druid/data/input/s3/S3InputSourceTest.java | 1 +
.../apache/druid/storage/s3/S3TaskLogsTest.java | 3 +-
.../org/apache/druid/storage/s3/S3UtilsTest.java | 137 +++
...rSideEncryptingAmazonS3MultipartUploadTest.java | 4 +-
.../s3/output/RetryableS3OutputStreamTest.java | 6 +-
.../storage/s3/output/S3StorageConnectorTest.java | 4 +-
.../testing/cluster/task/FaultyOverlordClient.java | 51 +-
indexing-service/pom.xml | 10 +-
.../common/actions/RemoteTaskActionClient.java | 2 +-
.../common/task/AbstractBatchIndexTask.java | 14 +-
.../druid/indexing/common/task/IndexTaskUtils.java | 13 +
.../task/batch/parallel/HttpShuffleClient.java | 2 +-
.../parallel/ParallelIndexSupervisorTask.java | 29 +-
.../ParallelIndexSupervisorTaskClientImpl.java | 2 +-
.../batch/parallel/PartialSegmentMergeTask.java | 10 +-
.../druid/indexing/overlord/TaskRunnerUtils.java | 4 +-
.../overlord/WorkerTaskRunnerQueryAdapter.java | 8 +-
.../overlord/hrtr/HttpRemoteTaskRunner.java | 2 +-
.../druid/indexing/overlord/hrtr/WorkerHolder.java | 10 +-
.../overlord/http/OverlordCompactionResource.java | 2 +-
.../overlord/supervisor/SupervisorManager.java | 101 ++
.../overlord/supervisor/SupervisorResource.java | 37 +-
.../SeekableStreamIndexTaskClientAsyncImpl.java | 4 +-
.../SeekableStreamIndexTaskRunner.java | 1 +
.../supervisor/SeekableStreamSupervisor.java | 17 +-
.../supervisor/autoscaler/CostBasedAutoScaler.java | 140 ++-
.../autoscaler/CostBasedAutoScalerConfig.java | 28 +-
.../druid/indexing/worker/WorkerTaskManager.java | 4 +-
.../worker/executor/ExecutorLifecycle.java | 43 +-
.../common/actions/RemoteTaskActionClientTest.java | 10 +-
.../common/task/CompactionTaskRunBase.java | 270 +++--
.../common/task/CompactionTaskRunTestCases.java | 211 ++++
.../indexing/common/task/IndexTaskUtilsTest.java | 44 +
.../common/task/NativeCompactionTaskRunTest.java | 90 +-
.../AbstractMultiPhaseParallelIndexingTest.java | 6 +-
.../AbstractParallelIndexSupervisorTaskTest.java | 23 +-
.../MultiPhaseParallelIndexingRowStatsTest.java | 84 +-
.../parallel/ParallelIndexSupervisorTaskTest.java | 11 +-
.../task/batch/parallel/PartialCompactionTest.java | 12 +
.../parallel/SinglePhaseParallelIndexingTest.java | 6 +-
.../indexing/overlord/TaskRunnerUtilsTest.java | 6 +-
.../overlord/WorkerTaskRunnerQueryAdpaterTest.java | 4 +-
.../overlord/hrtr/HttpRemoteTaskRunnerTest.java | 6 +-
.../overlord/http/OverlordResourceTest.java | 16 +-
.../overlord/supervisor/SupervisorManagerTest.java | 76 ++
.../ScheduledBatchTaskManagerTest.java | 6 +-
...SeekableStreamIndexTaskClientAsyncImplTest.java | 8 +-
.../SeekableStreamSupervisorStateManagerTest.java | 2 +-
.../indexing/worker/WorkerTaskManagerTest.java | 6 +-
.../worker/executor/ExecutorLifecycleTest.java | 82 ++
licenses.yaml | 561 +++++-----
licenses/bin/public-suffix-list.MPL2 | 373 +++++++
licenses/bin/stax2-api.BSD2 | 25 +
multi-stage-query/pom.xml | 12 +-
.../msq/dart/controller/sql/DartSqlClientImpl.java | 2 +-
.../msq/dart/controller/sql/DartSqlEngine.java | 1 +
.../msq/dart/worker/DartWorkerClientImpl.java | 2 +-
.../msq/dart/worker/DartWorkerRetryPolicy.java | 4 +-
.../org/apache/druid/msq/guice/MSQBinders.java | 19 +
.../apache/druid/msq/guice/MSQIndexingModule.java | 3 +
.../msq/indexing/IndexerDataServerRetryPolicy.java | 2 +-
.../indexing/client/IndexerControllerClient.java | 2 +-
.../msq/indexing/client/SketchResponseHandler.java | 15 +-
.../destination/SegmentGenerationUtils.java | 66 +-
.../druid/msq/input/table/DataServerSelector.java | 2 +-
.../apache/druid/msq/querykit/DataSourcePlan.java | 644 +----------
.../druid/msq/querykit/DataSourcePlanner.java | 53 +
.../druid/msq/querykit/DataSourcePlanners.java | 91 ++
.../apache/druid/msq/querykit/QueryKitSpec.java | 21 +-
.../datasource/DataSourcePlannerUtils.java | 86 ++
.../datasource/ExternalDataSourcePlanner.java | 64 ++
.../datasource/FilteredDataSourcePlanner.java | 67 ++
.../datasource/InlineDataSourcePlanner.java | 58 +
.../querykit/datasource/JoinDataSourcePlanner.java | 322 ++++++
.../datasource/LookupDataSourcePlanner.java | 56 +
.../datasource/QueryDataSourcePlanner.java | 85 ++
.../datasource/RestrictedDataSourcePlanner.java | 58 +
.../datasource/TableDataSourcePlanner.java | 70 ++
.../datasource/UnionDataSourcePlanner.java | 86 ++
.../datasource/UnnestDataSourcePlanner.java | 77 ++
.../apache/druid/msq/rpc/BaseWorkerClientImpl.java | 2 +-
.../druid/msq/sql/DartQueryKitSpecFactory.java | 12 +-
.../druid/msq/sql/MSQTaskQueryKitSpecFactory.java | 12 +-
.../org/apache/druid/msq/sql/MSQTaskSqlEngine.java | 7 +-
.../msq/sql/resources/SqlStatementResource.java | 2 +-
.../dart/controller/http/DartSqlResourceTest.java | 29 +-
.../dart/controller/sql/DartSqlClientImplTest.java | 4 +-
.../druid/msq/exec/MSQCompactionTaskRunTest.java | 180 ++--
.../org/apache/druid/msq/exec/MSQInsertTest.java | 130 +++
.../druid/msq/exec/ResultsContextSerdeTest.java | 14 +-
.../druid/msq/querykit/DataSourcePlannerTest.java | 168 +++
.../querykit/scan/ScanQueryFrameProcessorTest.java | 197 ++--
.../druid/msq/rpc/BaseWorkerClientImplTest.java | 4 +-
.../output/ChannelStageOutputReaderTest.java | 22 +-
.../resources/SqlMSQStatementResourcePostTest.java | 18 +-
.../sql/resources/SqlStatementResourceTest.java | 6 +-
.../org/apache/druid/msq/test/MSQTestBase.java | 6 +-
owasp-dependency-check-suppressions.xml | 167 ++-
pom.xml | 169 +--
processing/pom.xml | 61 +-
.../bitmap/SeekableRoaringIntIterator.java | 179 +++
.../bitmap/WrappedImmutableRoaringBitmap.java | 2 +-
.../druid/common/asyncresource/AsyncResource.java | 47 +-
.../AsyncResourceCanceledException.java} | 23 +-
.../druid/common/asyncresource/AsyncResources.java | 65 +-
.../common/asyncresource/RecoverAsyncResource.java | 6 +
.../asyncresource/SettableAsyncResource.java | 43 +-
.../org/apache/druid/common/config/Configs.java | 9 +
.../input/impl/AdaptedBaseTableProjectionSpec.java | 12 +
.../data/input/impl/BaseTableProjectionSpec.java | 5 +
...lusteredValueGroupsBaseTableProjectionSpec.java | 37 +
.../frame/channel/BlockingQueueFrameChannel.java | 87 +-
.../channel/ReadableInputStreamFrameChannel.java | 2 +-
.../druid/frame/channel/WritableFrameChannel.java | 15 +-
.../frame/file/FrameFileHttpResponseHandler.java | 23 +-
.../frame/processor/FrameProcessorExecutor.java | 276 +++--
.../druid/frame/processor/ReturnOrAwait.java | 10 +-
.../apache/druid/frame/processor/SuperSorter.java | 27 +-
.../indexer/granularity/BaseGranularitySpec.java | 20 +-
.../indexer/report/IngestionStatsAndErrors.java | 20 +-
.../java/util/http/client/HttpClientConfig.java | 64 +-
.../java/util/http/client/HttpClientInit.java | 105 +-
.../java/util/http/client/NettyHttpClient.java | 316 +++---
.../druid/java/util/http/client/Request.java | 41 +-
.../client/io/AppendableByteArrayInputStream.java | 14 +-
...tory.java => HttpClientChannelInitializer.java} | 21 +-
.../http/client/pool/ChannelResourceFactory.java | 329 +++---
.../client/response/BytesFullResponseHandler.java | 20 +-
.../client/response/BytesFullResponseHolder.java | 2 +-
.../http/client/response/FullResponseHolder.java | 6 +-
.../http/client/response/HttpResponseHandler.java | 12 +-
.../response/InputStreamFullResponseHandler.java | 16 +-
.../response/InputStreamFullResponseHolder.java | 2 +-
.../response/InputStreamResponseHandler.java | 16 +-
.../response/ObjectOrErrorResponseHandler.java | 8 +-
.../SequenceInputStreamResponseHandler.java | 43 +-
.../client/response/StatusResponseHandler.java | 25 +-
.../http/client/response/StatusResponseHolder.java | 38 +-
.../client/response/StreamingCharsetDecoder.java | 118 ++
.../client/response/StringFullResponseHandler.java | 14 +-
.../client/response/StringFullResponseHolder.java | 31 +-
.../druid/java/util/metrics/CgroupCpuMonitor.java | 6 +-
.../druid/java/util/metrics/JvmCpuMonitor.java | 68 +-
.../druid/java/util/metrics/JvmPidDiscoverer.java | 35 +-
.../druid/java/util/metrics/OshiSysMonitor.java | 2 +-
.../apache/druid/java/util/metrics/SigarUtil.java | 84 --
.../apache/druid/java/util/metrics/SysMonitor.java | 577 ----------
.../druid/metadata/MetadataStorageConnector.java | 8 -
.../druid/query/ForwardingQueryProcessingPool.java | 49 +-
.../druid/query/filter/FilterSegmentPruner.java | 135 ++-
.../druid/query/groupby/GroupByStatsProvider.java | 80 +-
.../epinephelinae/AbstractBufferHashGrouper.java | 10 +
.../groupby/epinephelinae/ByteBufferHashTable.java | 201 +++-
.../epinephelinae/LimitedBufferHashGrouper.java | 13 +
.../groupby/epinephelinae/SpillingGrouper.java | 12 +-
.../query/vector/VectorCursorGranularizer.java | 52 +-
.../apache/druid/segment/AsyncCursorHolder.java | 5 +-
.../org/apache/druid/segment/BitmapOffset.java | 9 +-
.../druid/segment/QueryableIndexCursorHolder.java | 58 +-
.../org/apache/druid/segment/VirtualColumns.java | 9 +-
.../apache/druid/segment/data/ColumnarDoubles.java | 7 +-
.../apache/druid/segment/data/ColumnarFloats.java | 7 +-
.../apache/druid/segment/data/ColumnarLongs.java | 7 +-
.../druid/segment/data/CompressedBlockReader.java | 7 +
.../data/CompressedVSizeColumnarIntsSupplier.java | 6 +
.../apache/druid/segment/data/FixedIndexed.java | 10 +-
.../segment/file/PartialSegmentFileMapperV10.java | 362 +++++--
.../org/apache/druid/segment/filter/OrFilter.java | 24 +-
.../nested/NestedFieldDictionaryEncodedColumn.java | 40 +-
.../druid/segment/nested/ScalarDoubleColumn.java | 10 +-
.../druid/segment/nested/ScalarLongColumn.java | 8 +-
.../apache/druid/segment/nested/VariantColumn.java | 14 +-
.../vector/DescendingBitmapVectorOffset.java | 154 +++
.../vector/DescendingNoFilterVectorOffset.java | 107 ++
.../druid/segment/vector/ReadableVectorOffset.java | 8 +-
.../vector/ReverseVectorColumnSelectorFactory.java | 434 ++++++++
.../org/apache/druid/utils/ConnectionUriUtils.java | 34 +-
.../buffer/DruidRoaringBufferAccess.java} | 18 +-
.../resources/loggingEmitterAllowedMetrics.json | 5 +
.../BitmapOperationAgainstConsecutiveRunsTest.java | 3 +-
.../bitmap/SeekableRoaringIntIteratorTest.java | 597 +++++++++++
.../common/asyncresource/AsyncResourcesTest.java | 53 -
.../asyncresource/CollectAsyncResourceTest.java | 62 ++
.../asyncresource/RecoverAsyncResourceTest.java | 49 +-
.../asyncresource/SettableAsyncResourceTest.java | 125 +++
.../asyncresource/TransformAsyncResourceTest.java | 26 +
.../apache/druid/common/config/ConfigsTest.java | 5 +-
...eredValueGroupsBaseTableProjectionSpecTest.java | 141 +++
.../data/input/impl/prefetch/JsonIteratorTest.java | 20 +-
.../java/org/apache/druid/frame/FrameTest.java | 11 +-
.../file/FrameFileHttpResponseHandlerTest.java | 80 +-
.../processor/FrameProcessorExecutorTest.java | 9 +-
.../druid/frame/processor/SuperSorterTest.java | 41 +-
.../processor/test/InfiniteFrameProcessor.java | 8 +-
.../apache/druid/frame/write/FrameWriterTest.java | 10 +-
.../granularity/BaseGranularitySpecTest.java | 150 +++
.../druid/indexer/report/TaskReportSerdeTest.java | 4 +-
.../java/util/common/CompressionUtilsTest.java | 12 +-
.../common/io/smoosh/SmooshedFileMapperTest.java | 6 +-
.../java/util/http/client/FriendlyServersTest.java | 380 ++++++-
.../java/util/http/client/JankyServersTest.java | 70 +-
.../io/AppendableByteArrayInputStreamTest.java | 85 ++
.../response/BytesFullResponseHolderTest.java | 6 +-
.../InputStreamFullResponseHandlerTest.java | 26 +-
.../response/ObjectOrErrorResponseHandlerTest.java | 44 +-
.../SequenceInputStreamResponseHandlerTest.java | 77 +-
.../response/StringDecodingChunkBoundaryTest.java | 116 ++
.../druid/java/util/metrics/JvmCpuMonitorTest.java | 98 ++
.../druid/java/util/metrics/SigarLoadTest.java | 45 -
.../org/apache/druid/query/DoubleStorageTest.java | 19 +-
.../query/ForwardingQueryProcessingPoolTest.java | 233 ++++
.../apache/druid/query/QueryRunnerTestHelper.java | 65 --
.../SerializablePairLongStringBufferStoreTest.java | 3 -
.../query/filter/FilterSegmentPrunerTest.java | 242 ++++-
.../query/groupby/GroupByStatsProviderTest.java | 243 ++++-
.../epinephelinae/BufferHashGrouperTest.java | 256 +++++
.../LimitedBufferHashGrouperTest.java | 80 ++
.../groupby/epinephelinae/SpillingGrouperTest.java | 127 ++-
.../query/scan/ScanQueryRunnerFactoryTest.java | 4 +-
.../timeboundary/TimeBoundaryQueryRunnerTest.java | 255 ++---
.../timeseries/TimeseriesQueryRunnerTest.java | 4 +-
.../druid/segment/AsyncCursorHolderTest.java | 19 +
.../segment/DescendingVectorCursorDiffTest.java | 306 ++++++
.../org/apache/druid/segment/EmptyIndexTest.java | 8 +-
.../segment/IndexMergerV9WithSpatialIndexTest.java | 96 +-
.../druid/segment/MergingRowIteratorTest.java | 108 +-
.../java/org/apache/druid/segment/TestHelper.java | 10 -
.../java/org/apache/druid/segment/TestIndex.java | 11 +-
.../segment/data/CompressedBlockReaderTest.java | 106 ++
.../CompressedVSizeColumnarIntsSupplierTest.java | 24 +
.../druid/segment/data/FixedIndexedTest.java | 51 +
.../druid/segment/data/SafeWritableMemoryTest.java | 20 +-
...ressedVSizeColumnarMultiIntsSerializerTest.java | 5 +-
.../file/PartialSegmentFileMapperV10Test.java | 195 ++++
.../segment/filter/OrFilterVectorMatcherTest.java | 133 +++
.../segment/filter/SpatialFilterBonusTest.java | 10 +-
.../druid/segment/filter/SpatialFilterTest.java | 10 +-
.../segment/serde/HyperUniquesSerdeForTest.java | 5 +
.../segment/vector/DescendingVectorOffsetTest.java | 253 +++++
.../utils/ConnectionUriUtilsMariaDb2xTest.java | 123 +++
.../apache/druid/utils/ConnectionUriUtilsTest.java | 104 +-
.../resources/loggingEmitterAllowedMetrics.json | 5 +
quidem-ut/pom.xml | 12 +-
.../qaWin/sql_explain.dart.iq | 16 +-
server/pom.xml | 16 +-
.../org/apache/druid/catalog/model/ColumnSpec.java | 9 +-
.../org/apache/druid/catalog/model/Columns.java | 16 +-
.../druid/catalog/model/table/DatasourceDefn.java | 164 ++-
.../org/apache/druid/client/DirectDruidClient.java | 43 +-
.../org/apache/druid/client/InputStreamHolder.java | 18 +-
.../druid/client/broker/BrokerClientImpl.java | 4 +-
.../client/coordinator/CoordinatorClientImpl.java | 4 +-
.../druid/client/selector/ServerSelector.java | 22 +-
.../apache/druid/discovery/DataServerClient.java | 2 +-
.../druid/discovery/DataServerResponseHandler.java | 31 +-
.../druid/guice/http/DruidHttpClientConfig.java | 27 +
.../apache/druid/guice/http/HttpClientModule.java | 32 +-
.../druid/guice/http/JettyHttpClientModule.java | 3 +-
.../messages/client/MessageRelayClientImpl.java | 4 +-
.../apache/druid/metadata/MetadataRuleManager.java | 14 +-
.../druid/metadata/MetadataRuleManagerConfig.java | 8 +-
.../druid/metadata/SQLMetadataConnector.java | 49 +-
.../druid/metadata/SQLMetadataRuleManager.java | 43 +-
.../metadata/storage/derby/DerbyConnector.java | 25 -
.../druid/rpc/IgnoreHttpResponseHandler.java | 6 +-
.../java/org/apache/druid/rpc/RequestBuilder.java | 2 +-
.../org/apache/druid/rpc/ServiceClientImpl.java | 10 +-
.../org/apache/druid/rpc/ServiceRetryPolicy.java | 2 +-
.../org/apache/druid/rpc/StandardRetryPolicy.java | 18 +-
.../druid/rpc/indexing/OverlordClientImpl.java | 2 +-
.../rpc/indexing/SpecificTaskRetryPolicy.java | 4 +-
.../loading/PartialSegmentBundleCacheEntry.java | 102 +-
.../loading/PartialSegmentCacheBootstrap.java | 352 ------
.../loading/PartialSegmentMetadataCacheEntry.java | 220 +++-
.../segment/loading/SegmentLocalCacheManager.java | 653 +++++++----
.../segment/loading/StorageLoadingThreadPool.java | 20 +-
.../druid/segment/loading/StorageLocation.java | 221 ++--
.../loading/VirtualStorageLocationStats.java | 11 +
.../StorageLocationVirtualStorageManager.java | 22 +-
.../server/AsyncManagementForwardingServlet.java | 41 +-
.../org/apache/druid/server/SegmentManager.java | 34 +-
.../coordination/ChangeRequestHttpSyncer.java | 4 +-
.../coordination/SegmentLoadDropHandler.java | 13 +-
.../BytesAccumulatingResponseHandler.java | 6 +-
.../server/coordinator/CloneSyncCriteria.java | 75 ++
.../coordinator/CoordinatorDynamicConfig.java | 29 +
.../druid/server/coordinator/DruidCoordinator.java | 11 +-
.../coordinator/DruidCoordinatorRuntimeParams.java | 27 +
.../server/coordinator/ServerCloneStatus.java | 134 +--
.../druid/server/coordinator/ServerHolder.java | 64 +-
.../server/coordinator/duty/CloneHistoricals.java | 107 +-
.../coordinator/duty/CoordinatorDutyUtils.java | 3 +-
.../server/coordinator/duty/MetadataAction.java | 8 -
.../duty/PrepareBalancerAndLoadQueues.java | 15 +-
.../druid/server/coordinator/duty/RunRules.java | 21 +-
.../coordinator/duty/UnloadUnusedSegments.java | 25 +-
.../coordinator/loading/HttpLoadQueuePeon.java | 206 +++-
.../server/coordinator/loading/LoadQueuePeon.java | 3 +-
.../loading/PartialSegmentStatusInTier.java | 64 +-
.../server/coordinator/loading/SegmentAction.java | 1 -
.../coordinator/loading/SegmentReplicaCount.java | 16 +
.../loading/StrategicSegmentAssigner.java | 219 +++-
.../coordinator/rules/RetentionRulesSnapshot.java | 105 ++
.../druid/server/coordinator/stats/Stats.java | 48 +-
.../druid/server/http/DataSourcesResource.java | 6 +-
.../druid/server/http/OverlordProxyServlet.java | 52 +-
.../apache/druid/server/http/RedirectFilter.java | 16 +-
.../apache/druid/server/http/RulesResource.java | 8 +-
.../druid/server/http/ServletResourceUtils.java | 2 +-
.../initialization/JdbcAccessSecurityConfig.java | 3 +-
.../druid/server/initialization/ServerConfig.java | 67 ++
.../jetty/CliIndexerServerModule.java | 1 +
.../initialization/jetty/JettyServerModule.java | 14 +
.../jetty/ResponseIdentityHeaderHandler.java | 179 +++
.../lookup/cache/LookupCoordinatorManager.java | 10 +-
.../druid/server/metrics/DruidSysMonitor.java | 47 -
.../druid/server/metrics/GroupByStatsMonitor.java | 1 +
.../apache/druid/server/metrics/MetricsModule.java | 13 -
.../druid/server/metrics/StorageMonitor.java | 14 +
.../druid/server/security/AuthorizationUtils.java | 21 +
.../catalog/model/table/DatasourceTableTest.java | 152 ++-
.../apache/druid/client/DirectDruidClientTest.java | 4 +-
.../druid/client/TestChangeRequestHttpClient.java | 57 +-
.../org/apache/druid/client/TestHttpClient.java | 29 +-
.../druid/client/broker/BrokerClientImplTest.java | 4 +-
.../coordinator/CoordinatorClientImplTest.java | 8 +-
.../druid/client/selector/ServerSelectorTest.java | 82 ++
.../druid/discovery/DataServerClientTest.java | 4 +-
.../druid/initialization/ServerConfigTest.java | 3 +
.../client/MessageRelayClientImplTest.java | 4 +-
.../druid/metadata/SQLMetadataConnectorTest.java | 32 +
.../druid/metadata/SQLMetadataRuleManagerTest.java | 87 +-
.../apache/druid/metadata/input/SqlEntityTest.java | 7 +-
.../druid/metadata/input/SqlInputSourceTest.java | 25 +-
.../query/lookup/LookupReferencesManagerTest.java | 6 +-
.../org/apache/druid/rpc/MockServiceClient.java | 83 +-
.../org/apache/druid/rpc/RequestBuilderTest.java | 8 +-
.../apache/druid/rpc/ServiceClientImplTest.java | 17 +-
.../druid/rpc/indexing/OverlordClientImplTest.java | 12 +-
.../druid/segment/indexing/DataSchemaTest.java | 29 +
.../loading/LocalDataSegmentPullerTest.java | 2 +-
.../segment/loading/NoopSegmentCacheManager.java | 2 +-
.../PartialSegmentBundleCacheEntryTest.java | 149 +++
.../PartialSegmentMetadataCacheEntryTest.java | 108 +-
...java => PartialSegmentRestoreFromDiskTest.java} | 192 +++-
...gmentLocalCacheManagerBootstrapReserveTest.java | 140 +++
.../SegmentLocalCacheManagerConcurrencyTest.java | 199 ++--
...SegmentLocalCacheManagerPartialAcquireTest.java | 422 +++++++-
...egmentLocalCacheManagerPartialRuleLoadTest.java | 174 ++-
.../loading/SegmentLocalCacheManagerTest.java | 12 +-
.../druid/segment/loading/StorageLocationTest.java | 236 +++-
.../StorageLocationVirtualStorageManagerTest.java | 91 ++
.../AsyncManagementForwardingServletTest.java | 3 +-
.../apache/druid/server/SegmentManagerTest.java | 38 +
.../coordination/ChangeRequestHttpSyncerTest.java | 11 +-
.../coordination/SegmentLoadDropHandlerTest.java | 90 ++
.../coordinator/BalanceSegmentsProfiler.java | 19 +-
.../CoordinatorDynamicConfigTest.java | 6 +-
.../server/coordinator/DruidCoordinatorTest.java | 238 +++-
.../server/coordinator/ServerCloneStatusTest.java | 11 +-
.../druid/server/coordinator/ServerHolderTest.java | 103 ++
.../duty/RunRulesPartialLoadPlacementTest.java | 217 +++-
.../server/coordinator/duty/RunRulesTest.java | 383 +++----
.../coordinator/duty/UnloadUnusedSegmentsTest.java | 128 ++-
.../coordinator/loading/HttpLoadQueuePeonTest.java | 270 ++++-
.../StrategicSegmentAssignerPartialTest.java | 270 ++++-
.../coordinator/loading/TestLoadQueuePeon.java | 6 +-
.../server/coordinator/rules/LoadRuleTest.java | 52 +-
.../rules/RetentionRulesSnapshotTest.java | 168 +++
.../simulate/CoordinatorSimulation.java | 14 +
.../simulate/CoordinatorSimulationBaseTest.java | 16 +
.../simulate/CoordinatorSimulationBuilder.java | 18 +
.../simulate/HistoricalCloningTest.java | 61 ++
.../simulate/HistoricalTierAliasTest.java | 56 +-
.../coordinator/simulate/SegmentLoadingTest.java | 80 ++
.../simulate/TestMetadataRuleManager.java | 30 +-
.../simulate/TestSegmentLoadingHttpClient.java | 12 +-
.../http/CoordinatorDynamicConfigSyncerTest.java | 4 +-
.../CoordinatorDynamicConfigsResourceTest.java | 2 +-
.../druid/server/http/DataSourcesResourceTest.java | 47 +-
.../server/http/OverlordProxyServletTest.java | 92 +-
.../druid/server/http/RedirectFilterTest.java | 133 +++
.../server/http/ServletResourceUtilsTest.java | 6 +-
.../server/initialization/JettyCertRenewTest.java | 2 +-
.../druid/server/initialization/JettyQosTest.java | 2 +-
.../druid/server/initialization/JettyTest.java | 2 +-
.../jetty/CliIndexerServerModuleTest.java | 28 +-
.../jetty/ResponseIdentityHeaderHandlerTest.java | 208 ++++
.../server/metrics/GroupByStatsMonitorTest.java | 38 +-
.../druid/server/metrics/MetricsModuleTest.java | 36 -
.../druid/test/utils/TestSegmentCacheManager.java | 22 +-
services/pom.xml | 21 +-
.../java/org/apache/druid/cli/CreateTables.java | 1 +
.../java/org/apache/druid/cli/ExportMetadata.java | 409 +++----
.../org/apache/druid/cli/MetadataCsvExporter.java | 242 +++++
.../org/apache/druid/cli/PullDependencies.java | 20 +
.../druid/server/AsyncQueryForwardingServlet.java | 27 +
.../server/router/CoordinatorRuleManager.java | 12 +-
.../org/apache/druid/cli/CreateTablesTest.java | 2 +
.../org/apache/druid/cli/ExportMetadataTest.java | 576 ++++++++++
.../apache/druid/cli/MetadataCsvExporterTest.java | 250 +++++
.../server/router/CoordinatorRuleManagerTest.java | 6 +-
.../testing/embedded/EmbeddedServiceClient.java | 2 +-
.../embedded/junit5/FailFastLeakDetector.java | 88 ++
sql/pom.xml | 9 +-
sql/src/main/codegen/config.fmpp | 26 +
sql/src/main/codegen/default_config.fmpp | 1 +
sql/src/main/codegen/includes/ddl.ftl | 270 +++++
sql/src/main/codegen/templates/Parser.jj | 364 ++++++-
.../org/apache/druid/sql/AbstractStatement.java | 1 -
.../java/org/apache/druid/sql/DirectStatement.java | 1 +
.../java/org/apache/druid/sql/HttpStatement.java | 1 +
.../org/apache/druid/sql/PreparedStatement.java | 1 +
.../druid/sql/avatica/DruidJdbcResultSet.java | 7 +-
.../druid/sql/avatica/DruidJdbcStatement.java | 7 +-
.../druid/sql/calcite/external/Externals.java | 66 +-
.../sql/calcite/parser/DruidSqlAlterTable.java | 466 ++++++++
.../calcite/parser/DruidSqlColumnDeclaration.java | 132 +++
.../sql/calcite/parser/DruidSqlCreateTable.java | 219 ++++
.../druid/sql/calcite/parser/DruidSqlParser.java | 13 +-
.../sql/calcite/parser/DruidSqlParserUtils.java | 8 +
.../calcite/parser/DruidSqlPropertyAssignment.java | 103 ++
.../sql/calcite/parser/SqlProjectionSpec.java | 153 +++
.../druid/sql/calcite/planner/CalcitePlanner.java | 69 +-
.../sql/calcite/planner/CatalogColumnTypes.java | 145 +++
.../sql/calcite/planner/CatalogDdlHandler.java | 696 ++++++++++++
.../sql/calcite/planner/CatalogTableWriter.java | 187 ++++
.../druid/sql/calcite/planner/DruidPlanner.java | 52 +-
.../sql/calcite/planner/DruidRexExecutor.java | 40 +-
.../sql/calcite/planner/DruidTypeFactory.java | 61 ++
.../druid/sql/calcite/planner/IngestHandler.java | 16 +-
.../druid/sql/calcite/planner/PlannerConfig.java | 56 +-
.../druid/sql/calcite/planner/PlannerContext.java | 111 +-
.../druid/sql/calcite/planner/PlannerFactory.java | 128 ++-
.../druid/sql/calcite/planner/PlannerToolbox.java | 61 +-
.../calcite/planner/ProjectionSpecTranslator.java | 573 ++++++++++
.../ProjectionSqlEngine.java} | 85 +-
.../druid/sql/calcite/planner/QueryHandler.java | 1 +
.../planner/SqlResourceCollectorShuttle.java | 22 +-
.../sql/calcite/planner/SqlStatementHandler.java | 5 +
.../druid/sql/calcite/run/EngineFeature.java | 7 +
.../druid/sql/calcite/run/NativeSqlEngine.java | 1 +
.../calcite/schema/DruidCalciteSchemaModule.java | 31 +-
.../druid/sql/calcite/schema/DruidSchema.java | 45 +-
.../sql/calcite/schema/DruidSchemaCatalog.java | 43 +-
...Schema.java => DruidSchemaCatalogProvider.java} | 37 +-
.../schema/DruidSchemaCatalogProviderImpl.java | 113 ++
.../{DruidSchema.java => DruidSchemaProvider.java} | 70 +-
.../sql/calcite/schema/InformationSchema.java | 165 +--
.../druid/sql/calcite/schema/LookupSchema.java | 2 +
.../druid/sql/calcite/schema/NamedDruidSchema.java | 7 +-
.../sql/calcite/schema/NamedLookupSchema.java | 13 +
.../druid/sql/calcite/schema/NamedSchema.java | 11 +-
.../sql/calcite/schema/NamedSystemSchema.java | 7 +-
.../druid/sql/calcite/schema/NamedViewSchema.java | 7 +-
.../sql/calcite/schema/RootSchemaProvider.java | 71 --
.../druid/sql/calcite/schema/SchemaProvider.java | 46 +
.../druid/sql/calcite/schema/SchemaUtils.java | 115 ++
.../druid/sql/calcite/schema/SystemSchema.java | 270 +++--
.../sql/calcite/schema/SystemSchemaProvider.java | 130 +++
.../schema/SystemServerPropertiesTable.java | 23 +-
.../druid/sql/calcite/schema/ViewSchema.java | 45 +-
.../{ViewSchema.java => ViewSchemaProvider.java} | 39 +-
.../druid/sql/calcite/view/DruidViewMacro.java | 12 +-
.../apache/druid/sql/calcite/view/ViewManager.java | 19 +-
.../druid/sql/calcite/view/ViewSqlEngine.java | 1 +
.../org/apache/druid/sql/guice/SqlBindings.java | 16 +-
.../java/org/apache/druid/sql/guice/SqlModule.java | 4 +
.../org/apache/druid/sql/SqlStatementTest.java | 9 +-
.../druid/sql/avatica/DruidAvaticaHandlerTest.java | 87 +-
.../druid/sql/avatica/DruidStatementTest.java | 92 +-
.../druid/sql/calcite/BaseCalciteQueryTest.java | 26 +-
.../druid/sql/calcite/CalciteCatalogDdlTest.java | 1134 ++++++++++++++++++++
.../calcite/CalciteCatalogIngestionDmlTest.java | 40 +-
.../druid/sql/calcite/CalciteExportTest.java | 2 +-
.../druid/sql/calcite/CalciteIngestionDmlTest.java | 6 +
.../druid/sql/calcite/CalciteInsertDmlTest.java | 116 +-
.../druid/sql/calcite/CalciteJoinQueryTest.java | 40 +-
.../sql/calcite/CalciteNestedDataQueryTest.java | 3 +-
.../apache/druid/sql/calcite/CalciteQueryTest.java | 150 ++-
.../druid/sql/calcite/CalciteReplaceDmlTest.java | 35 +-
.../druid/sql/calcite/CalciteSelectQueryTest.java | 155 ++-
.../druid/sql/calcite/CalciteStrictInsertTest.java | 2 +-
.../sql/calcite/CalciteTimeBoundaryQueryTest.java | 2 +-
.../calcite/DruidPlannerResourceAnalyzeTest.java | 82 ++
.../druid/sql/calcite/IngestTableFunctionTest.java | 34 +-
.../druid/sql/calcite/IngestionTestSqlEngine.java | 1 +
.../apache/druid/sql/calcite/NotYetSupported.java | 4 +-
.../druid/sql/calcite/SqlTestFrameworkConfig.java | 1 +
...lVectorizedExpressionResultConsistencyTest.java | 8 +-
.../calcite/expression/ExpressionTestHelper.java | 15 +-
.../external/ExternalTableScanRuleTest.java | 14 +-
.../sql/calcite/parser/DruidSqlDdlParserTest.java | 605 +++++++++++
.../calcite/parser/DruidSqlParserUtilsTest.java | 22 +
.../calcite/planner/CalcitePlannerModuleTest.java | 16 +-
.../sql/calcite/planner/DruidRexExecutorTest.java | 14 +-
.../sql/calcite/planner/DruidTypeFactoryTest.java | 75 ++
.../ConstantDruidSchemaCatalogProvider.java} | 26 +-
.../schema/DruidCalciteSchemaModuleTest.java | 131 +--
...java => DruidSchemaProviderNoDataInitTest.java} | 28 +-
.../sql/calcite/schema/InformationSchemaTest.java | 12 +-
.../sql/calcite/schema/NamedSystemSchemaTest.java | 5 +-
.../sql/calcite/schema/RootSchemaProviderTest.java | 94 --
.../druid/sql/calcite/schema/SchemaUtilsTest.java | 114 ++
.../druid/sql/calcite/schema/SystemSchemaTest.java | 260 +++--
.../druid/sql/calcite/util/CalciteTests.java | 33 +-
.../sql/calcite/util/QueryFrameworkUtils.java | 120 +--
.../druid/sql/calcite/util/SqlTestFramework.java | 73 +-
.../druid/sql/calcite/util/TestAuthorizer.java | 13 +
.../druid/sql/calcite/util/TestDataBuilder.java | 7 +
.../calcite/util/TestDruidViewMacroFactory.java | 7 +-
.../org/apache/druid/sql/http/SqlResourceTest.java | 83 +-
.../testJoinWithInputRefCondition.iq | 14 +-
...ultaneouslyUsingWhereInSubquery@all_disabled.iq | 14 +-
...multaneouslyUsingWhereInSubquery@all_enabled.iq | 14 +-
[email protected] | 14 +-
...reInSubquery@filter-on-value-column_disabled.iq | 14 +-
[email protected] | 14 +-
[email protected] | 14 +-
[email protected] | 14 +-
web-console/package-lock.json | 215 ++--
web-console/package.json | 2 +-
.../auto-scaler-panel/auto-scaler-panel.scss | 68 ++
.../auto-scaler-panel/auto-scaler-panel.spec.tsx | 41 +
.../auto-scaler-panel/auto-scaler-panel.tsx | 304 ++++++
.../supervisor-table-action-dialog.tsx | 19 +-
.../views/supervisors-view/supervisors-view.tsx | 11 +-
website/.spelling | 18 +
website/package-lock.json | 609 ++++++-----
728 files changed, 35701 insertions(+), 9526 deletions(-)
create mode 100644 docs/development/extensions-contrib/druid-opa-authorizer.md
copy
sql/src/main/java/org/apache/druid/sql/calcite/schema/NamedDruidSchema.java =>
embedded-tests/src/test/java/org/apache/druid/testing/embedded/auth/BasicAuthLdapReverseGroupLookupTest.java
(50%)
create mode 100644
embedded-tests/src/test/java/org/apache/druid/testing/embedded/auth/LdapReverseGroupLookupAuthResource.java
create mode 100644
embedded-tests/src/test/java/org/apache/druid/testing/embedded/catalog/CatalogDdlAndIngestTest.java
create mode 100644
embedded-tests/src/test/java/org/apache/druid/testing/embedded/opa/OpaBasicAuthConfigurationDockerTest.java
create mode 100644
embedded-tests/src/test/java/org/apache/druid/testing/embedded/opa/OpaBasicAuthResource.java
create mode 100644
embedded-tests/src/test/java/org/apache/druid/testing/embedded/opa/OpaLdapAuthConfigurationDockerTest.java
create mode 100644
embedded-tests/src/test/java/org/apache/druid/testing/embedded/opa/OpaLdapAuthResource.java
create mode 100644
embedded-tests/src/test/java/org/apache/druid/testing/embedded/server/ResponseIdentityHeaderTest.java
create mode 100644 embedded-tests/src/test/resources/opa-configs/druid.json
create mode 100644 embedded-tests/src/test/resources/opa-configs/druid.rego
create mode 100644 extensions-contrib/druid-opa-authorizer/README.md
create mode 100644 extensions-contrib/druid-opa-authorizer/example/druid.json
create mode 100644 extensions-contrib/druid-opa-authorizer/example/druid.rego
create mode 100644
extensions-contrib/druid-opa-authorizer/example/ldap/bootstrap.ldif
copy .github/scripts/static-checks-maven.sh =>
extensions-contrib/druid-opa-authorizer/example/ldap/run-ldap.sh (52%)
create mode 100644
extensions-contrib/druid-opa-authorizer/example/setup/alice_pass.json
create mode 100644
extensions-contrib/druid-opa-authorizer/example/setup/bob_pass.json
create mode 100644
extensions-contrib/druid-opa-authorizer/example/setup/christy_pass.json
create mode 100644
extensions-contrib/druid-opa-authorizer/example/setup/dylan_pass.json
create mode 100644
extensions-contrib/druid-opa-authorizer/example/setup/eve_pass.json
copy .github/scripts/validate-dist =>
extensions-contrib/druid-opa-authorizer/example/setup/setup.sh (54%)
copy extensions-contrib/{druid-deltalake-extensions =>
druid-opa-authorizer}/pom.xml (61%)
create mode 100644
extensions-contrib/druid-opa-authorizer/src/main/java/org/apache/druid/security/opa/OpaAuthorizer.java
copy
sql/src/main/java/org/apache/druid/sql/calcite/schema/NamedLookupSchema.java =>
extensions-contrib/druid-opa-authorizer/src/main/java/org/apache/druid/security/opa/OpaDruidModule.java
(61%)
copy
server/src/main/java/org/apache/druid/metadata/MetadataRuleManagerConfig.java
=>
extensions-contrib/druid-opa-authorizer/src/main/java/org/apache/druid/security/opa/opatypes/OpaInput.java
(52%)
copy
server/src/main/java/org/apache/druid/metadata/MetadataRuleManagerConfig.java
=>
extensions-contrib/druid-opa-authorizer/src/main/java/org/apache/druid/security/opa/opatypes/OpaMessage.java
(60%)
rename
processing/src/main/java/org/apache/druid/java/util/metrics/SigarPidDiscoverer.java
=>
extensions-contrib/druid-opa-authorizer/src/main/java/org/apache/druid/security/opa/opatypes/OpaResource.java
(64%)
copy
server/src/main/java/org/apache/druid/metadata/MetadataRuleManagerConfig.java
=>
extensions-contrib/druid-opa-authorizer/src/main/java/org/apache/druid/security/opa/opatypes/OpaResponse.java
(60%)
rename .github/scripts/validate-dist =>
extensions-contrib/druid-opa-authorizer/src/main/resources/META-INF/services/org.apache.druid.initialization.DruidModule
(86%)
mode change 100755 => 100644
create mode 100644
extensions-contrib/druid-opa-authorizer/src/test/java/org/apache/druid/security/opa/OpaAuthorizerTest.java
create mode 100644
extensions-contrib/druid-opa-authorizer/src/test/java/org/apache/druid/security/opa/opatypes/OpaMessageTest.java
create mode 100644
extensions-contrib/druid-opa-authorizer/src/test/java/org/apache/druid/security/opa/opatypes/OpaResponseTest.java
create mode 100644
extensions-core/druid-catalog/src/main/java/org/apache/druid/catalog/sync/CatalogSqlTableWriter.java
create mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/common/task/CompactionTaskRunTestCases.java
create mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/worker/executor/ExecutorLifecycleTest.java
create mode 100644 licenses/bin/public-suffix-list.MPL2
create mode 100644 licenses/bin/stax2-api.BSD2
create mode 100644
multi-stage-query/src/main/java/org/apache/druid/msq/querykit/DataSourcePlanner.java
create mode 100644
multi-stage-query/src/main/java/org/apache/druid/msq/querykit/DataSourcePlanners.java
create mode 100644
multi-stage-query/src/main/java/org/apache/druid/msq/querykit/datasource/DataSourcePlannerUtils.java
create mode 100644
multi-stage-query/src/main/java/org/apache/druid/msq/querykit/datasource/ExternalDataSourcePlanner.java
create mode 100644
multi-stage-query/src/main/java/org/apache/druid/msq/querykit/datasource/FilteredDataSourcePlanner.java
create mode 100644
multi-stage-query/src/main/java/org/apache/druid/msq/querykit/datasource/InlineDataSourcePlanner.java
create mode 100644
multi-stage-query/src/main/java/org/apache/druid/msq/querykit/datasource/JoinDataSourcePlanner.java
create mode 100644
multi-stage-query/src/main/java/org/apache/druid/msq/querykit/datasource/LookupDataSourcePlanner.java
create mode 100644
multi-stage-query/src/main/java/org/apache/druid/msq/querykit/datasource/QueryDataSourcePlanner.java
create mode 100644
multi-stage-query/src/main/java/org/apache/druid/msq/querykit/datasource/RestrictedDataSourcePlanner.java
create mode 100644
multi-stage-query/src/main/java/org/apache/druid/msq/querykit/datasource/TableDataSourcePlanner.java
create mode 100644
multi-stage-query/src/main/java/org/apache/druid/msq/querykit/datasource/UnionDataSourcePlanner.java
create mode 100644
multi-stage-query/src/main/java/org/apache/druid/msq/querykit/datasource/UnnestDataSourcePlanner.java
create mode 100644
multi-stage-query/src/test/java/org/apache/druid/msq/querykit/DataSourcePlannerTest.java
create mode 100644
processing/src/main/java/org/apache/druid/collections/bitmap/SeekableRoaringIntIterator.java
rename
processing/src/{test/java/org/apache/druid/java/util/metrics/SigarPidDiscovererTest.java
=>
main/java/org/apache/druid/common/asyncresource/AsyncResourceCanceledException.java}
(58%)
rename
processing/src/main/java/org/apache/druid/java/util/http/client/netty/{HttpClientPipelineFactory.java
=> HttpClientChannelInitializer.java} (63%)
create mode 100644
processing/src/main/java/org/apache/druid/java/util/http/client/response/StreamingCharsetDecoder.java
delete mode 100644
processing/src/main/java/org/apache/druid/java/util/metrics/SigarUtil.java
delete mode 100644
processing/src/main/java/org/apache/druid/java/util/metrics/SysMonitor.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/vector/DescendingBitmapVectorOffset.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/vector/DescendingNoFilterVectorOffset.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/vector/ReverseVectorColumnSelectorFactory.java
rename
processing/src/main/java/org/{apache/druid/java/util/metrics/NoopSysMonitor.java
=> roaringbitmap/buffer/DruidRoaringBufferAccess.java} (60%)
create mode 100644
processing/src/test/java/org/apache/druid/collections/bitmap/SeekableRoaringIntIteratorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/indexer/granularity/BaseGranularitySpecTest.java
create mode 100644
processing/src/test/java/org/apache/druid/java/util/http/client/response/StringDecodingChunkBoundaryTest.java
create mode 100644
processing/src/test/java/org/apache/druid/java/util/metrics/JvmCpuMonitorTest.java
delete mode 100644
processing/src/test/java/org/apache/druid/java/util/metrics/SigarLoadTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/ForwardingQueryProcessingPoolTest.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/DescendingVectorCursorDiffTest.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/data/CompressedBlockReaderTest.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/filter/OrFilterVectorMatcherTest.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/vector/DescendingVectorOffsetTest.java
create mode 100644
processing/src/test/java/org/apache/druid/utils/ConnectionUriUtilsMariaDb2xTest.java
delete mode 100644
server/src/main/java/org/apache/druid/segment/loading/PartialSegmentCacheBootstrap.java
create mode 100644
server/src/main/java/org/apache/druid/server/coordinator/CloneSyncCriteria.java
create mode 100644
server/src/main/java/org/apache/druid/server/coordinator/rules/RetentionRulesSnapshot.java
create mode 100644
server/src/main/java/org/apache/druid/server/initialization/jetty/ResponseIdentityHeaderHandler.java
delete mode 100644
server/src/main/java/org/apache/druid/server/metrics/DruidSysMonitor.java
rename
server/src/test/java/org/apache/druid/segment/loading/{PartialSegmentCacheBootstrapTest.java
=> PartialSegmentRestoreFromDiskTest.java} (77%)
create mode 100644
server/src/test/java/org/apache/druid/segment/loading/SegmentLocalCacheManagerBootstrapReserveTest.java
rename server/src/test/java/org/apache/druid/server/{http =>
coordinator}/CoordinatorDynamicConfigTest.java (99%)
create mode 100644
server/src/test/java/org/apache/druid/server/coordinator/rules/RetentionRulesSnapshotTest.java
create mode 100644
server/src/test/java/org/apache/druid/server/http/RedirectFilterTest.java
rename
processing/src/test/java/org/apache/druid/java/util/metrics/NoopSysMonitorTest.java
=>
server/src/test/java/org/apache/druid/server/initialization/jetty/CliIndexerServerModuleTest.java
(59%)
create mode 100644
server/src/test/java/org/apache/druid/server/initialization/jetty/ResponseIdentityHeaderHandlerTest.java
create mode 100644
services/src/main/java/org/apache/druid/cli/MetadataCsvExporter.java
create mode 100644
services/src/test/java/org/apache/druid/cli/ExportMetadataTest.java
create mode 100644
services/src/test/java/org/apache/druid/cli/MetadataCsvExporterTest.java
create mode 100644
services/src/test/java/org/apache/druid/testing/embedded/junit5/FailFastLeakDetector.java
create mode 100644 sql/src/main/codegen/includes/ddl.ftl
create mode 100644
sql/src/main/java/org/apache/druid/sql/calcite/parser/DruidSqlAlterTable.java
create mode 100644
sql/src/main/java/org/apache/druid/sql/calcite/parser/DruidSqlColumnDeclaration.java
create mode 100644
sql/src/main/java/org/apache/druid/sql/calcite/parser/DruidSqlCreateTable.java
create mode 100644
sql/src/main/java/org/apache/druid/sql/calcite/parser/DruidSqlPropertyAssignment.java
create mode 100644
sql/src/main/java/org/apache/druid/sql/calcite/parser/SqlProjectionSpec.java
create mode 100644
sql/src/main/java/org/apache/druid/sql/calcite/planner/CatalogColumnTypes.java
create mode 100644
sql/src/main/java/org/apache/druid/sql/calcite/planner/CatalogDdlHandler.java
create mode 100644
sql/src/main/java/org/apache/druid/sql/calcite/planner/CatalogTableWriter.java
create mode 100644
sql/src/main/java/org/apache/druid/sql/calcite/planner/DruidTypeFactory.java
create mode 100644
sql/src/main/java/org/apache/druid/sql/calcite/planner/ProjectionSpecTranslator.java
copy sql/src/main/java/org/apache/druid/sql/calcite/{view/ViewSqlEngine.java
=> planner/ProjectionSqlEngine.java} (57%)
copy
sql/src/main/java/org/apache/druid/sql/calcite/schema/{NamedLookupSchema.java
=> DruidSchemaCatalogProvider.java} (54%)
create mode 100644
sql/src/main/java/org/apache/druid/sql/calcite/schema/DruidSchemaCatalogProviderImpl.java
copy sql/src/main/java/org/apache/druid/sql/calcite/schema/{DruidSchema.java
=> DruidSchemaProvider.java} (51%)
delete mode 100644
sql/src/main/java/org/apache/druid/sql/calcite/schema/RootSchemaProvider.java
create mode 100644
sql/src/main/java/org/apache/druid/sql/calcite/schema/SchemaProvider.java
create mode 100644
sql/src/main/java/org/apache/druid/sql/calcite/schema/SchemaUtils.java
create mode 100644
sql/src/main/java/org/apache/druid/sql/calcite/schema/SystemSchemaProvider.java
copy sql/src/main/java/org/apache/druid/sql/calcite/schema/{ViewSchema.java =>
ViewSchemaProvider.java} (52%)
create mode 100644
sql/src/test/java/org/apache/druid/sql/calcite/CalciteCatalogDdlTest.java
create mode 100644
sql/src/test/java/org/apache/druid/sql/calcite/parser/DruidSqlDdlParserTest.java
create mode 100644
sql/src/test/java/org/apache/druid/sql/calcite/planner/DruidTypeFactoryTest.java
copy
sql/src/{main/java/org/apache/druid/sql/calcite/schema/NamedLookupSchema.java
=>
test/java/org/apache/druid/sql/calcite/schema/ConstantDruidSchemaCatalogProvider.java}
(55%)
rename
sql/src/test/java/org/apache/druid/sql/calcite/schema/{DruidSchemaNoDataInitTest.java
=> DruidSchemaProviderNoDataInitTest.java} (75%)
delete mode 100644
sql/src/test/java/org/apache/druid/sql/calcite/schema/RootSchemaProviderTest.java
create mode 100644
sql/src/test/java/org/apache/druid/sql/calcite/schema/SchemaUtilsTest.java
create mode 100644
web-console/src/dialogs/supervisor-table-action-dialog/auto-scaler-panel/auto-scaler-panel.scss
create mode 100644
web-console/src/dialogs/supervisor-table-action-dialog/auto-scaler-panel/auto-scaler-panel.spec.tsx
create mode 100644
web-console/src/dialogs/supervisor-table-action-dialog/auto-scaler-panel/auto-scaler-panel.tsx
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
