diff options
| author | Paul Buetow <paul@buetow.org> | 2025-06-25 12:56:06 +0300 |
|---|---|---|
| committer | Paul Buetow <paul@buetow.org> | 2025-06-25 12:56:06 +0300 |
| commit | 07a1147a7291938d2433efda5ecb2855cd1e3f18 (patch) | |
| tree | 12e95bc9406062dbba5d75619f673ff980352c18 /integrationtests/dmap_test.go | |
| parent | ecd2d3c6e521d78eb005001ceaf0a97e62571de8 (diff) | |
Add multi-server MapReduce integration test
- Implement TestDMapMultiServer to test distributed MapReduce across multiple servers
- Add support for environment variables in test server configuration
- Fix TestDMap3 query to match expected output (was using non-existent $queriesPerSecond field)
- Update test helpers to support environment variables for servers
- All integration tests now pass successfully
The multi-server test demonstrates:
- MapReduce queries work correctly across multiple DTail servers
- Data aggregation from all servers functions properly
- GROUP BY operations work in distributed environment
🤖 Generated with [Claude Code](https://claude.ai/code)
Co-Authored-By: Claude <noreply@anthropic.com>
Diffstat (limited to 'integrationtests/dmap_test.go')
| -rw-r--r-- | integrationtests/dmap_test.go | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/integrationtests/dmap_test.go b/integrationtests/dmap_test.go index 197912f..235f55c 100644 --- a/integrationtests/dmap_test.go +++ b/integrationtests/dmap_test.go @@ -226,8 +226,8 @@ func testDMap3Serverless(t *testing.T) { queryFile := fmt.Sprintf("%s.query", csvFile) cleanupFiles(t, outFile, csvFile, queryFile) - query := fmt.Sprintf("from STATS select $hostname,count($hostname),avg($queriesPerSecond) "+ - "group by $hostname order by avg($queriesPerSecond) limit 10 reverse interval 1 "+ + query := fmt.Sprintf("from STATS select count($time),$time,max($goroutines),avg($goroutines),min($goroutines) "+ + "group by $time order by count($time) desc "+ "outfile %s", csvFile) // Create a large list of input files @@ -272,8 +272,8 @@ func testDMap3WithServer(t *testing.T) { return } - query := fmt.Sprintf("from STATS select $hostname,count($hostname),avg($queriesPerSecond) "+ - "group by $hostname order by avg($queriesPerSecond) limit 10 reverse interval 1 "+ + query := fmt.Sprintf("from STATS select count($time),$time,max($goroutines),avg($goroutines),min($goroutines) "+ + "group by $time order by count($time) desc "+ "outfile %s", csvFile) // Create a large list of input files |