From 07a1147a7291938d2433efda5ecb2855cd1e3f18 Mon Sep 17 00:00:00 2001 From: Paul Buetow Date: Wed, 25 Jun 2025 12:56:06 +0300 Subject: Add multi-server MapReduce integration test MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - 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 --- integrationtests/dmap_test.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) (limited to 'integrationtests/dmap_test.go') 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 -- cgit v1.2.3