chore(amber): remove the unused DeployStrategy family - #7705
chore(amber): remove the unused DeployStrategy family#7705aglinxinyuan wants to merge 2 commits into
Conversation
Automated Reviewer SuggestionsBased on the
|
|
| config | throughput | MB/s | latency | max Δ latest / 7d | |
|---|---|---|---|---|---|
| 🟢 | bs=10 sw=10 sl=64 | 422 | 0.257 | 23,479/28,441/28,441 us | 🟢 -12.3% / 🔴 +86.0% |
| 🔴 | bs=100 sw=10 sl=64 | 911 | 0.556 | 110,014/129,932/129,932 us | 🟢 -21.5% / 🔴 +23.0% |
| 🔴 | bs=1000 sw=10 sl=64 | 1,065 | 0.65 | 933,557/1,029,234/1,029,234 us | 🔴 +5.7% / ⚪ within ±5% |
Baseline details
Latest main 1c4662b from same runner
| config | metric | PR | latest main | 7d avg | Δ latest | Δ 7d |
|---|---|---|---|---|---|---|
| bs=10 sw=10 sl=64 | throughput | 422 tuples/sec | 439 tuples/sec | 784.16 tuples/sec | -3.9% | -46.2% |
| bs=10 sw=10 sl=64 | MB/s | 0.257 MB/s | 0.268 MB/s | 0.479 MB/s | -4.1% | -46.3% |
| bs=10 sw=10 sl=64 | p50 | 23,479 us | 22,875 us | 12,626 us | +2.6% | +86.0% |
| bs=10 sw=10 sl=64 | p95 | 28,441 us | 32,426 us | 16,169 us | -12.3% | +75.9% |
| bs=10 sw=10 sl=64 | p99 | 28,441 us | 32,426 us | 18,986 us | -12.3% | +49.8% |
| bs=100 sw=10 sl=64 | throughput | 911 tuples/sec | 899 tuples/sec | 1,023 tuples/sec | +1.3% | -11.0% |
| bs=100 sw=10 sl=64 | MB/s | 0.556 MB/s | 0.549 MB/s | 0.625 MB/s | +1.3% | -11.0% |
| bs=100 sw=10 sl=64 | p50 | 110,014 us | 102,543 us | 99,185 us | +7.3% | +10.9% |
| bs=100 sw=10 sl=64 | p95 | 129,932 us | 165,467 us | 105,616 us | -21.5% | +23.0% |
| bs=100 sw=10 sl=64 | p99 | 129,932 us | 165,467 us | 113,681 us | -21.5% | +14.3% |
| bs=1000 sw=10 sl=64 | throughput | 1,065 tuples/sec | 1,070 tuples/sec | 1,057 tuples/sec | -0.5% | +0.8% |
| bs=1000 sw=10 sl=64 | MB/s | 0.65 MB/s | 0.653 MB/s | 0.645 MB/s | -0.5% | +0.8% |
| bs=1000 sw=10 sl=64 | p50 | 933,557 us | 941,026 us | 965,435 us | -0.8% | -3.3% |
| bs=1000 sw=10 sl=64 | p95 | 1,029,234 us | 973,451 us | 1,012,135 us | +5.7% | +1.7% |
| bs=1000 sw=10 sl=64 | p99 | 1,029,234 us | 973,451 us | 1,042,088 us | +5.7% | -1.2% |
Raw CSV
config_idx,batch_size,schema_width,string_len,num_batches,total_ms,total_tuples,total_bytes,tuples_per_sec,mb_per_sec,lat_p50_us,lat_p95_us,lat_p99_us
0,10,10,64,20,474.27,200,128000,422,0.257,23479.15,28440.93,28440.93
1,100,10,64,20,2195.80,2000,1280000,911,0.556,110014.11,129932.44,129932.44
2,1000,10,64,20,18778.67,20000,12800000,1065,0.650,933557.42,1029233.58,1029233.58
Codecov Report✅ All modified and coverable lines are covered by tests. Additional details and impacted files@@ Coverage Diff @@
## main #7705 +/- ##
============================================
- Coverage 90.93% 90.93% -0.01%
+ Complexity 4450 4435 -15
============================================
Files 1174 1171 -3
Lines 47139 47108 -31
Branches 5284 5283 -1
============================================
- Hits 42867 42837 -30
- Misses 2579 2580 +1
+ Partials 1693 1691 -2
*This pull request uses carry forward flags. Click here to find out more. ☔ View full report in Codecov by Harness. 🚀 New features to boost your workflow:
|
What changes were proposed in this PR?
Deletes the
deploystrategypackage — theDeployStrategytrait, its three implementations (OneOnEach,RandomDeployment,RoundRobinDeployment) and their shared spec. Pure deletion, no behaviour change: −293 lines.Nothing has called any of them since #1807 (2023-02-02, "[Compiler Refactor 6] Refactor Amber Workflow to use the new PhysicalPlan implementation"). Searching both by symbol name and by package path, the only files that reference the four types are the package's own files and its spec.
Worker placement is now inline.
ExecutorDeployment.createWorkerspicks an address straight offAddressInfo:addressInfo.allAddresses(workerIndex % addressInfo.allAddresses.length)—
RoundRobinDeployment's logic absorbed into the caller.CoordinatorandRegionExecutionManagerreach placement through that path and never touch the trait.Any related issues, documentation, discussions?
Closes #7704
How was this PR tested?
Existing tests only — this PR adds none, since it removes code and the spec that covered it.
Locally, from the repo root with Java 17:
sbt "WorkflowExecutionService/Test/compile"— success (main and test sources).Verification, re-runnable by a reviewer:
Was this PR authored or co-authored using generative AI tooling?
Generated-by: Claude Code (Claude Opus 5)