[Cosmos] Add azure-cosmos-avad-test module for AVAD Change Feed Processor soak testing#49050

Draft

jeet1995 wants to merge 31 commits intoAzure:mainfrom

jeet1995:users/abhmohanty/cosmos-avad-test

Commits on May 4, 2026

Add azure-cosmos-avad-test module for AVAD Change Feed Processor soak testing

jeet1995
and
Copilot
committed
Move AVAD soak test into azure-cosmos-benchmark module

jeet1995
and
Copilot
committed

Commits on May 5, 2026

Fix AVAD code to Java 8 compatibility for benchmark module

jeet1995
and
Copilot
committed
Fix self-review findings: blocking bugs, watch issues, and chaos scope

jeet1995
and
Copilot
committed
Revert unrelated hooks.json change

jeet1995
and
Copilot
committed
Refactor Ingestor to use Cosmos bulk API

jeet1995
and
Copilot
committed
Remove unused SoakMetrics class

jeet1995
and
Copilot
committed
Align close() pattern across all components

jeet1995
and
Copilot
committed
Share CosmosAsyncClient between workload and ReconciliationWriter

jeet1995
and
Copilot
committed
Replace inline fully qualified names with imports

jeet1995
and
Copilot
committed
Add JSON-based configuration with env var overrides

jeet1995
and
Copilot
committed
Add local + AKS orchestration scripts

jeet1995
and
Copilot
committed
Fix: remove unsupported setStartTime for AVAD CFP mode

jeet1995
and
Copilot
committed
Fix: enable contentResponseOnWrite on all clients

jeet1995
and
Copilot
committed
Make ReconciliationWriter synchronous

jeet1995
and
Copilot
committed
Fix ingestor bulk response correlation with IdentityHashMap

jeet1995
and
Copilot
committed
Fix ingestor: replace Flux.interval+concatMap with blocking loop

jeet1995
and
Copilot
committed
Remove inline CRTS tracking from AvadReader

jeet1995
and
Copilot
committed
Propagate ReconciliationWriter failures to handleChanges

jeet1995
and
Copilot
committed
Remove soak-health container — use offline Reconciler instead

jeet1995
and
Copilot
committed
Redesign reconciliation: Cosmos-only, per-reader, 5 sources

jeet1995
and
Copilot
committed
Add Spark LV and AVAD change feed reader notebooks

jeet1995
and
Copilot
committed
Add Spark-based reconciler notebook

jeet1995
and
Copilot
committed
Fix Dockerfile: use -cp with explicit main class, local build

jeet1995
and
Copilot
committed
Tune CFP throughput: bulk recon writes, faster polling, region alignment

jeet1995
and
Copilot
committed

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

[Cosmos] Add azure-cosmos-avad-test module for AVAD Change Feed Processor soak testing#49050

[Cosmos] Add azure-cosmos-avad-test module for AVAD Change Feed Processor soak testing#49050
jeet1995 wants to merge 31 commits intoAzure:mainfrom
jeet1995:users/abhmohanty/cosmos-avad-test

Commits on May 4, 2026

Add azure-cosmos-avad-test module for AVAD Change Feed Processor soak testing

Move AVAD soak test into azure-cosmos-benchmark module

Commits on May 5, 2026

Fix AVAD code to Java 8 compatibility for benchmark module

Fix self-review findings: blocking bugs, watch issues, and chaos scope

Revert unrelated hooks.json change

Refactor Ingestor to use Cosmos bulk API

Remove unused SoakMetrics class

Align close() pattern across all components

Share CosmosAsyncClient between workload and ReconciliationWriter

Replace inline fully qualified names with imports

Add JSON-based configuration with env var overrides

Add local + AKS orchestration scripts

Fix: remove unsupported setStartTime for AVAD CFP mode

Fix: enable contentResponseOnWrite on all clients

Make ReconciliationWriter synchronous

Fix ingestor bulk response correlation with IdentityHashMap

Fix ingestor: replace Flux.interval+concatMap with blocking loop

Remove inline CRTS tracking from AvadReader

Propagate ReconciliationWriter failures to handleChanges

Remove soak-health container — use offline Reconciler instead

Redesign reconciliation: Cosmos-only, per-reader, 5 sources

Add Spark LV and AVAD change feed reader notebooks

Add Spark-based reconciler notebook

Fix Dockerfile: use -cp with explicit main class, local build

Tune CFP throughput: bulk recon writes, faster polling, region alignment

Commits on May 6, 2026

Fix Spark notebooks: widget config, checkpoint path, column schema

Fix Spark AVAD: use AllVersionsAndDeletes mode, startFrom=Now

Fix Spark AVAD reader: disable schema inference, use AVAD columns

Fix Spark reconciler: handle missing columns gracefully

Add runId scoping to all components and reconciliation

Propagate runId from orchestration scripts to all components