You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@chukwa.apache.org by ey...@apache.org on 2009/06/12 19:52:09 UTC
svn commit: r784220 - /hadoop/chukwa/trunk/conf/aggregator.sql
Author: eyang
Date: Fri Jun 12 17:52:08 2009
New Revision: 784220
URL: http://svn.apache.org/viewvc?rev=784220&view=rev
Log:
CHUKWA-253. Fixed group by condition in the SQL statement. (Eric Yang)
Modified:
hadoop/chukwa/trunk/conf/aggregator.sql
Modified: hadoop/chukwa/trunk/conf/aggregator.sql
URL: http://svn.apache.org/viewvc/hadoop/chukwa/trunk/conf/aggregator.sql?rev=784220&r1=784219&r2=784220&view=diff
==============================================================================
--- hadoop/chukwa/trunk/conf/aggregator.sql (original)
+++ hadoop/chukwa/trunk/conf/aggregator.sql Fri Jun 12 17:52:08 2009
@@ -124,7 +124,7 @@
replace into [mr_job_conf_year] (select * from [mr_job_conf_week] where ts between '[past_15_minutes]' and '[now]');
replace into [mr_job_conf_decade] (select * from [mr_job_conf_week] where ts between '[past_15_minutes]' and '[now]');
-replace into [user_job_summary_month] (select FLOOR(UNIX_TIMESTAMP(timestamp)/300),userid, sum(totalJobs), sum(dataLocalMaps), sum(rackLoaclMaps), sum(removeMaps), sum(mapInputBytes), sum(reduceOutputRecords), sum(mapSlotHours), sum(reduceSlotHours), sum(totalMaps), sum(totalReduces) from [user_job_summary_week] where ts between '[past_15_minutes]' and '[now]') group by FLOOR(UNIX_TIMESTAMP(timestamp)/300),userid);
-replace into [user_job_summary_quarter] (select FLOOR(UNIX_TIMESTAMP(timestamp)/1800),userid, sum(totalJobs), sum(dataLocalMaps), sum(rackLoaclMaps), sum(removeMaps), sum(mapInputBytes), sum(reduceOutputRecords), sum(mapSlotHours), sum(reduceSlotHours), sum(totalMaps), sum(totalReduces) from [user_job_summary_week] where ts between '[past_90_minutes]' and '[now]') group by FLOOR(UNIX_TIMESTAMP(timestamp)/1800),userid);
-replace into [user_job_summary_year] (select FLOOR(UNIX_TIMESTAMP(timestamp)/10800),userid, sum(totalJobs), sum(dataLocalMaps), sum(rackLoaclMaps), sum(removeMaps), sum(mapInputBytes), sum(reduceOutputRecords), sum(mapSlotHours), sum(reduceSlotHours), sum(totalMaps), sum(totalReduces) from [user_job_summary_week] where ts between '[past_540_minutes]' and '[now]') group by FLOOR(UNIX_TIMESTAMP(timestamp)/10800),userid);
-replace into [user_job_summary_decade] (select FLOOR(UNIX_TIMESTAMP(timestamp)/43200),userid, sum(totalJobs), sum(dataLocalMaps), sum(rackLoaclMaps), sum(removeMaps), sum(mapInputBytes), sum(reduceOutputRecords), sum(mapSlotHours), sum(reduceSlotHours), sum(totalMaps), sum(totalReduces) from [user_job_summary_week] where ts between '[past_2160_minutes]' and '[now]') group by FLOOR(UNIX_TIMESTAMP(timestamp)/43200),userid);
+replace into [user_job_summary_month] (select FLOOR(UNIX_TIMESTAMP(timestamp)/300),userid, sum(totalJobs), sum(dataLocalMaps), sum(rackLoaclMaps), sum(removeMaps), sum(mapInputBytes), sum(reduceOutputRecords), sum(mapSlotHours), sum(reduceSlotHours), sum(totalMaps), sum(totalReduces) from [user_job_summary_week] where ts between '[past_15_minutes]' and '[now]') group by FLOOR(UNIX_TIMESTAMP(timestamp)/300)),userid;
+replace into [user_job_summary_quarter] (select FLOOR(UNIX_TIMESTAMP(timestamp)/1800),userid, sum(totalJobs), sum(dataLocalMaps), sum(rackLoaclMaps), sum(removeMaps), sum(mapInputBytes), sum(reduceOutputRecords), sum(mapSlotHours), sum(reduceSlotHours), sum(totalMaps), sum(totalReduces) from [user_job_summary_week] where ts between '[past_90_minutes]' and '[now]') group by FLOOR(UNIX_TIMESTAMP(timestamp)/1800)),userid;
+replace into [user_job_summary_year] (select FLOOR(UNIX_TIMESTAMP(timestamp)/10800),userid, sum(totalJobs), sum(dataLocalMaps), sum(rackLoaclMaps), sum(removeMaps), sum(mapInputBytes), sum(reduceOutputRecords), sum(mapSlotHours), sum(reduceSlotHours), sum(totalMaps), sum(totalReduces) from [user_job_summary_week] where ts between '[past_540_minutes]' and '[now]') group by FLOOR(UNIX_TIMESTAMP(timestamp)/10800)),userid;
+replace into [user_job_summary_decade] (select FLOOR(UNIX_TIMESTAMP(timestamp)/43200),userid, sum(totalJobs), sum(dataLocalMaps), sum(rackLoaclMaps), sum(removeMaps), sum(mapInputBytes), sum(reduceOutputRecords), sum(mapSlotHours), sum(reduceSlotHours), sum(totalMaps), sum(totalReduces) from [user_job_summary_week] where ts between '[past_2160_minutes]' and '[now]') group by FLOOR(UNIX_TIMESTAMP(timestamp)/43200)),userid;