diff options
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 |