Skip to content
Draft
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
96 commits
Select commit Hold shift + click to select a range
b3202a9
Adding grpc interceptor to help with clearing up arrow buffer message…
harshavamsi May 28, 2026
097bf13
Drop DatetimeOutputCastRewriter on the analytics-engine route (sql#54…
mengweieric May 28, 2026
2575c34
[Analytics-Engine] Introduce a per-query context so front-ends and th…
mch2 May 29, 2026
e0404f4
analytics-engine: replica failover on shard dispatch failure (#21866)
mch2 May 29, 2026
81df508
Refactor distributed-aggregate rewriter (#21875)
vinaykpud May 29, 2026
700213c
Remove Allocator divisor setting on Parquet side (#21872)
rayshrey May 29, 2026
aaee6f5
[DFA Tiering / Block Cache] Defer H2W cancel write-block removal, add…
vishwasgarg18 May 29, 2026
ba395cb
Bind arrow-flight-rpc tests to a port range, not a single port (#21870)
andrross May 29, 2026
f249d49
Bump dependencies to address CVEs (#21879)
cwperks May 29, 2026
3aefe0f
[analytics-engine] Per-shard bucket oversampling for TopK aggregation…
sandeshkr419 May 30, 2026
71cac80
Unmute CoordinatorReduceIT TAKE/LIST/VALUES tests (#21901)
sandeshkr419 May 30, 2026
b186488
update sandbox tests to conditionally use ppl endpoint or test plugin…
mch2 May 30, 2026
bccad99
Set X-Opaque-Id in Log4j2 MDC for analytics engine request tracing (#…
finnegancarroll May 30, 2026
ad89448
analytics-engine: register delegation markers on all DataFusion sessi…
mch2 May 30, 2026
518f284
[Analytics-Engine] Lower LITERAL_AGG and accept all join condition sh…
songkant-aws May 30, 2026
dad63c0
Complete coordinator reduce cancellation (#21730)
aravindsagar May 30, 2026
6fc9f03
analytics-engine: map SMALLINT/TINYINT in the QTF Arrow converter (#2…
mch2 May 30, 2026
a772315
Coerce MemTable schema in derive_schema_from_partial_plan to fix Bina…
vinaykpud May 30, 2026
0bf7481
qa: fix lookup_join provisioning and rex_command goldens (#21909)
mch2 May 30, 2026
b6b121c
Filter rule: respect nested scalar-function capabilities when computi…
vinaykpud May 31, 2026
601fec6
Remove jqwik dependency, replace with OpenSearch randomized tests (#2…
mch2 May 31, 2026
53e32d8
analytics-eng: preserve a Sort under a Fetch in substrait conversion …
mch2 May 31, 2026
892063d
mute flaky ShardFailoverIT test (#21919)
mch2 May 31, 2026
12d62b8
[Backport 3.7] Bump dependencies to address CVEs (#21897)
andrross May 31, 2026
7c89c8d
[Backport 3.7] Update shadow-gradle-plugin to 9.4.2 (#21896)
andrross May 31, 2026
005a225
Truncate analytics result set at 10k rows to prevent OOM (#21916)
mch2 May 31, 2026
15e085c
[analytics-engine] Wire dc/earliest/latest/nth_value to DataFusion bu…
songkant-aws Jun 1, 2026
8c18294
mute faky test (#21921)
mch2 Jun 1, 2026
62311ad
analytics-engine: run query under framework AnalyticsQueryTask for HT…
mch2 Jun 1, 2026
0e5bee4
[analytics-engine] Wire PPL percentile_approx end-to-end (#21920)
sandeshkr419 Jun 1, 2026
4778c5c
[Arrow Flight RPC] Producer-side back-pressure under slow consumers (…
rishabhmaurya Jun 1, 2026
547a24d
Bridge integer FLOOR/CEIL/SIGN/TRUNCATE through DataFusion's fp64 UDF…
vinaykpud Jun 1, 2026
e778b87
feat: Wire up native cancellation stats from Rust to Java (#21802)
aravindsagar Jun 1, 2026
989b7f6
Fix filter delegation concurrency bug by threading context_id through…
aravindsagar Jun 1, 2026
d57367f
Fix Time32-vs-Arrow mismatch on PPL time queries (#21925)
vinaykpud Jun 1, 2026
d8b3904
Update shadow-gradle-plugin to 9.4.2 (#21895)
andrross Jun 1, 2026
cef6cca
Analytics Engine: Make reduce stage's initial partition count configu…
mch2 Jun 1, 2026
d513012
Bias cancellation select toward the token branch (#21924)
aravindsagar Jun 1, 2026
a3fab6b
[analytics engine] Add `/_plugins/_analytics/stats` endpoint (#21796)
OVI3D0 Jun 1, 2026
dee5928
Fix pure LIMIT: gather to coordinator before applying fetch (#21936)
mch2 Jun 2, 2026
4cafb38
Fix array_length return type mismatch (#21932)
vinaykpud Jun 2, 2026
4f6bcf5
[analytics-engine] Wire FINAL aggregate filter drop and join-conditio…
songkant-aws Jun 2, 2026
7b2d56f
Fix: Downgrade optional plugin dependency warning to a single info lo…
lazyfetch Jun 2, 2026
476f882
Add slow log support for analytics engine indexing and search paths (…
himshikhagupta Jun 2, 2026
7b43093
Lucene as a driving backend for shard-local count fragments (#21867)
alchemist51 Jun 2, 2026
44df9f9
Migrate discovery-ec2 plugin availability zone fetch to use IMDSv2 (#…
jawon-benchling Jun 2, 2026
8dadd37
Update ASM to 9.10.1 (#21945)
reta Jun 2, 2026
b0b1c25
Sandbox/qa - Add multi shard qa test suite (#21951)
mch2 Jun 2, 2026
95c2891
fix(search): make bitmap scorer repeatable (#21815)
gingeekrishna Jun 2, 2026
b722c82
[Analytics Engine] Let constant filter predicates reach the backend (…
ahkcs Jun 2, 2026
9f2f6e6
Add sample otel dataset (#21952)
prudhvigodithi Jun 3, 2026
1c4d0f5
IT: assert lastCommitFileName invariant under concurrent flush/refres…
ask-kamal-nayan Jun 3, 2026
169a005
Analytics-Engine: Reduce-input early termination & fix reduce thread …
mch2 Jun 3, 2026
f2aaaf9
[analytics-engine] Fix multi-input single-shard backend resolution in…
mch2 Jun 3, 2026
317edb0
Refactor datafusion plugin stats to node level metrics (#21846)
AjayRajNelapudi Jun 3, 2026
c71a758
fix(analytics-engine): correct cross-shard COUNT(DISTINCT) (#21961)
sandeshkr419 Jun 3, 2026
07beeba
[analytics-engine] Push non-aggregate sort below exchange (#21958)
sandeshkr419 Jun 3, 2026
7b5a672
fix bin on timestamp values (#21953)
vinaykpud Jun 3, 2026
422f323
Fixed empty index search failure (#21754)
vinaykpud Jun 3, 2026
d5756a7
Fsync data files before commit for crash-consistency & delete orphan …
Bukhtawar Jun 3, 2026
2336baf
Update Netty to 4.2.15.Final (#21944)
reta Jun 3, 2026
7896c11
Add new marker for SystemIndexDescriptor to allow tiered access when …
cwperks Jun 3, 2026
bbf73b2
Fix for converting SQL wildcard to Lucene syntax (#21739)
nssuresh2007 Jun 3, 2026
da56716
Test fix - ignore threak leaks (#21963)
rayshrey Jun 3, 2026
b13005c
Use constraints instead of force for plexus-utils (#21967)
andrross Jun 3, 2026
7822605
Disable stored fields for _id and omit norms for text fields in Lucen…
rayshrey Jun 3, 2026
2f639db
Fix ListingTable stats-merge failure on widened (alias/pattern) scans…
mch2 Jun 3, 2026
d20890f
[Analytics Engine] Add limit on max shards per query for alias, index…
mch2 Jun 3, 2026
2d343f5
mute flaky test testQuerySlowLogEmitsAllFieldsOnCoordinatorPath (#21971)
mch2 Jun 3, 2026
de0ebc4
Sandbox/qa - Extensive coverage test fixes (#21959)
mch2 Jun 3, 2026
3e97896
Refresh replication state during remote store migration (#21716)
HUSTERGS Jun 3, 2026
c32b31d
Close Kafka Consumer if KafkaPartitionConsumer fails to initialize (#…
msfroh Jun 3, 2026
0755be0
increase kafka metadata default read timeout to 30s (#21979)
varunbharadwaj Jun 4, 2026
6d98004
fix(analytics-engine): route exact COUNT(DISTINCT) through APPROX_COU…
sandeshkr419 Jun 4, 2026
75cf3bc
Improve sandbox check and add Cargo.lock for caching (#21976)
peterzhuamazon Jun 4, 2026
59cb89d
Wire earliest/latest as stats aggregations + extend 2-shard type cove…
mch2 Jun 4, 2026
c430d53
Fix TIMESTAMP/DATE arithmetic and DATE→TIMESTAMP cast (#21978)
vinaykpud Jun 4, 2026
a62c37f
Fix temp lucene_gen folder deletion (#21940)
rayshrey Jun 4, 2026
03bc45d
Fix cross-shard schema drift on the indexed-executor scan path (#21988)
mch2 Jun 4, 2026
a6568dd
Bump com.diffplug.spotless to 8.6.0 (#21977)
andrross Jun 4, 2026
25efd89
Add bloom filter pruning on the indexed parquet read path (#21904)
Bukhtawar Jun 4, 2026
682ce0e
Add filter-delegation ShapeBased IT and fix bug in predicate combiner…
expani Jun 4, 2026
db84aa5
Wait for warm index replica to catch up before search (#21969)
andrross Jun 4, 2026
7714d0f
[Bug fix] Remove CoalesceExec for chunk execution (#21994)
alchemist51 Jun 4, 2026
5dd382a
Share one IndexSearcher per Lucene reader in filter delegation (#21990)
mch2 Jun 4, 2026
3c93d64
Fix Netty4Http3ServerTransportTests sporadic test case failures (#22004)
reta Jun 4, 2026
253564c
Fix TopK oversampling to use the user's limit, not the system size ca…
mch2 Jun 5, 2026
209584b
[analytics-engine] Support PPL date_add/date_sub by lowering to DATET…
LantaoJin Jun 5, 2026
6ed2753
Add datafusion.spill_directory setting (#21913)
gaurav-amz Jun 5, 2026
881d5f2
Thread context_id through fetch-by-row-ids and indexed query paths fo…
himshikhagupta Jun 5, 2026
853f56c
Update Jackson 3 to 3.1.4, Jackson 2 to 2.22.0 (#22007)
reta Jun 5, 2026
76fff24
Fix SSE blob store reload during repository metadata update (#21825)
ask-kamal-nayan Jun 5, 2026
e5ec89a
Make /_plugins/_analytics/stats cluster-wide via TransportNodesAction…
OVI3D0 Jun 5, 2026
56502f4
Decorrelate correlated EXISTS subqueries by stripping the existence-i…
LantaoJin Jun 5, 2026
a82785c
[Arrow Flight RPC] Add metadata channel on ArrowBatchResponse (#22003)
rishabhmaurya Jun 5, 2026
1daa269
Add data node profiling via ArrowBatchResponse metadata channel
finnegancarroll Jun 5, 2026
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
The table of contents is too big for display.
Diff view
Diff view
  •  
  •  
  •  
13 changes: 13 additions & 0 deletions .github/workflows/sandbox-check.yml
Original file line number Diff line number Diff line change
@@ -1,7 +1,11 @@
name: Sandbox Check
on:
push:
paths:
- 'sandbox/**'
pull_request:
paths:
- 'sandbox/**'

concurrency:
group: ${{ github.workflow }}-${{ github.event.pull_request.number || github.run_id }}
Expand Down Expand Up @@ -32,6 +36,15 @@ jobs:
uses: dtolnay/rust-toolchain@29eef336d9b2848a0b548edc03f92a220660cdb8 # stable
- name: Install protobuf compiler
run: sudo apt-get update && sudo apt-get install -y protobuf-compiler
- name: Cache Cargo registry
uses: actions/cache@v4
with:
path: |
~/.cargo/registry
~/.cargo/git
key: ${{ runner.os }}-cargo-${{ hashFiles('sandbox/**/Cargo.lock') }}
- name: Set Cargo build jobs
run: echo "CARGO_BUILD_JOBS=$(nproc)" >> $GITHUB_ENV
- name: Run sandbox check
run: ./gradlew check -p sandbox -Dsandbox.enabled=true -PrustDebug
- name: Upload test results
Expand Down
2 changes: 1 addition & 1 deletion .gitignore
Original file line number Diff line number Diff line change
Expand Up @@ -72,6 +72,6 @@ testfixtures_shared/

# build files generated
doc-tools/missing-doclet/bin/
**/Cargo.lock

/sandbox/plugins/analytics-backend-datafusion/target/
/sandbox/libs/dataformat-native/rust/target
2 changes: 1 addition & 1 deletion build.gradle
Original file line number Diff line number Diff line change
Expand Up @@ -55,7 +55,7 @@ plugins {
id 'lifecycle-base'
id 'opensearch.docker-support'
id 'opensearch.global-build-info'
id "com.diffplug.spotless" version "8.4.0" apply false
id "com.diffplug.spotless" version "8.6.0" apply false
id "org.gradle.test-retry" version "1.6.2" apply false
id "test-report-aggregation"
id 'jacoco-report-aggregation'
Expand Down
12 changes: 10 additions & 2 deletions buildSrc/build.gradle
Original file line number Diff line number Diff line change
Expand Up @@ -125,19 +125,26 @@ dependencies {
api 'org.apache.rat:apache-rat:0.15'
api "commons-io:commons-io:${props.getProperty('commonsio')}"
api "net.java.dev.jna:jna:5.16.0"
api 'com.gradleup.shadow:shadow-gradle-plugin:9.3.1'
api 'com.gradleup.shadow:shadow-gradle-plugin:9.4.2'
api 'org.jdom:jdom2:2.0.6.1'
api "org.jetbrains.kotlin:kotlin-stdlib-jdk8:${props.getProperty('kotlin')}"
api 'de.thetaphi:forbiddenapis:3.10'
api 'com.avast.gradle:gradle-docker-compose-plugin:0.17.12'
api "org.yaml:snakeyaml:${props.getProperty('snakeyaml')}"
api 'org.apache.maven:maven-model:3.9.12'
api 'org.apache.maven:maven-model:3.9.16'
api 'org.codehaus.plexus:plexus-xml:3.0.1'
api 'com.networknt:json-schema-validator:1.2.0'
api 'org.jruby.jcodings:jcodings:1.0.58'
api 'org.jruby.joni:joni:2.2.6'
api "com.fasterxml.jackson.core:jackson-databind:${props.getProperty('jackson_databind')}"
api "org.ajoberstar.grgit:grgit-core:5.3.2"

constraints {
api('org.codehaus.plexus:plexus-utils:4.0.3') {
because 'fixes CVE-2025-67030'
}
}

testFixturesApi "junit:junit:${props.getProperty('junit')}"
testFixturesApi "com.carrotsearch.randomizedtesting:randomizedtesting-runner:${props.getProperty('randomizedrunner')}"
testFixturesApi gradleApi()
Expand All @@ -160,6 +167,7 @@ dependencies {
configurations.all {
resolutionStrategy {
force "com.google.guava:guava:${props.getProperty('guava')}"
force "org.apache.logging.log4j:log4j-core:${props.getProperty('log4j')}"
}
}

Expand Down
1 change: 0 additions & 1 deletion client/sniffer/licenses/jackson-core-3.1.3.jar.sha1

This file was deleted.

1 change: 1 addition & 0 deletions client/sniffer/licenses/jackson-core-3.1.4.jar.sha1
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
f9fd39204bd3d4922b42f6a54b81f46bd8ed575a
9 changes: 9 additions & 0 deletions distribution/src/config/opensearch.yml
Original file line number Diff line number Diff line change
Expand Up @@ -121,3 +121,12 @@ ${path.logs}
# Once there is no observed impact on performance, this feature flag can be removed.
#
#opensearch.experimental.optimization.datetime_formatter_caching.enabled: false
#
# Path to the spill directory used by the analytics-backend-datafusion plugin. When
# unset (default), spill is disabled and queries that exceed
# datafusion.memory_pool_limit_bytes will fail with a "DiskManager is disabled" error.
# Set this to a directory on a dedicated filesystem to enable spill — the directory
# should not contend with the data path. NodeScope, Final — DataFusion's DiskManager
# is built once at runtime startup.
#
#datafusion.spill_directory:
17 changes: 7 additions & 10 deletions gradle/libs.versions.toml
Original file line number Diff line number Diff line change
Expand Up @@ -8,19 +8,19 @@ bundled_jdk = "25.0.3+9"
# optional dependencies
spatial4j = "0.7"
jts = "1.15.0"
jackson_annotations = "2.21"
jackson = "2.21.3"
jackson_databind = "2.21.3"
jackson3 = "3.1.3"
jackson3_databind = "3.1.3"
jackson_annotations = "2.22"
jackson = "2.22.0"
jackson_databind = "2.22.0"
jackson3 = "3.1.4"
jackson3_databind = "3.1.4"
snakeyaml = "2.6"
snakeyaml_engine = "3.0.1"
icu4j = "77.1"
supercsv = "2.4.0"
log4j = "2.25.4"
error_prone_annotations = "2.45.0"
slf4j = "2.0.17"
asm = "9.10"
asm = "9.10.1"
jettison = "1.5.4"
woodstox = "6.4.0"
kotlin = "1.7.10"
Expand All @@ -40,7 +40,7 @@ json_smart = "2.5.2"
# when updating the JNA version, also update the version in buildSrc/build.gradle
jna = "5.16.0"

netty = "4.2.14.Final"
netty = "4.2.15.Final"
joda = "2.12.7"
roaringbitmap = "1.3.0"

Expand Down Expand Up @@ -110,9 +110,6 @@ calcite = "1.41.0"
calcite_os_rev = "1"

# property-based testing
jqwik = "1.9.2"
junit_jupiter = "5.11.3"
junit_platform = "1.11.3"
[libraries]
antlr4-runtime = { group = "org.antlr", name = "antlr4-runtime", version.ref = "antlr4" }
asm-analysis = { group = "org.ow2.asm", name = "asm-analysis", version.ref = "asm" }
Expand Down
1 change: 0 additions & 1 deletion libs/core/licenses/jackson-core-3.1.3.jar.sha1

This file was deleted.

1 change: 1 addition & 0 deletions libs/core/licenses/jackson-core-3.1.4.jar.sha1
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
f9fd39204bd3d4922b42f6a54b81f46bd8ed575a
Loading
Loading