# Patent

## Title
Energy-aware job scheduling for cluster environments

## Abstract

A job scheduler can select a processor core operating frequency for a node in a cluster to perform a job based on energy usage and performance data. After a job request is received, an energy aware job scheduler accesses data that specifies energy usage and job performance metrics that correspond to the requested job and a plurality of processor core operating frequencies. A first of the plurality of processor core operating frequencies is selected that satisfies an energy usage criterion for performing the job based, at least in part, on the data that specifies energy usage and job performance metrics that correspond to the job. The job is assigned to be performed by a node in the cluster at the selected first of the plurality of processor core operating frequencies.

## Background
RELATED APPLICATIONS
This continuation application claims the benefit under 35 U.S.C. §120 of U.S. patent application Ser. No. 12/917,421 filed Nov. 1, 2010. U.S. patent application Ser. No. 12/917,421 claims priority to European Patent Application No. 10305449.0, which was filed on Apr. 20, 2010.


BACKGROUND
Embodiments of the inventive subject matter generally relate to the field of energy conservation aware computing, and, more particularly, to energy-aware job scheduling for cluster environments.
Managing power consumption has become a serious concern to many high performance computing (HPC) data centers where large clusters are used for running parallel applications. The performance characteristics of a parallel application can range from processor intensive to memory bandwidth intensive. These performance characteristics affect power consumption. The Active Energy Manager (AEM) tool provides a comprehensive view of energy consumption in a data center. The AEM tool measures, monitors, and manages energy components built into systems. The AEM tool measures and monitors components by collecting power information of devices plugged into a power distribution unit. The AEM tool manages energy components with power capping and power savings mode.
SUMMARY
Embodiments include a method and a computer program product that access data that specifies energy usage and job performance metrics that correspond to a job and a plurality of processor core operating frequencies. The job has been requested of a cluster. A first of the plurality of processor core operating frequencies is selected that satisfies an energy usage criterion for performing the job based, at least in part, on the data that specifies energy usage and job performance metrics that correspond to the job. The job is assigned to be performed by a node in the cluster at the selected first of the plurality of processor core operating frequencies.



BRIEF DESCRIPTION OF THE DRAWINGS
The present embodiments may be better understood, and numerous objects, features, and advantages made apparent to those skilled in the art by referencing the accompanying drawings.
FIG. 1 depicts an example conceptual diagram of a system for selecting frequencies to perform jobs based on energy usage and performance metrics.
FIGS. 2 and 3 are flowcharts depicting example operations for selecting frequencies to run jobs based on energy usage and performance data.
FIG. 4 is a flowchart depicting example operations for determining coefficients of a regression model.
FIG. 5 depicts an example computer system with an energy aware job scheduler



DESCRIPTION OF EMBODIMENT(S)
The description that follows includes exemplary systems, methods, techniques, instruction sequences and computer program products that embody techniques of the present inventive subject matter. However, it is understood that the described embodiments may be practiced without these specific details. For instance, although examples refer to reducing frequencies of nodes in a cluster below a default processor core operating frequency, embodiments can increase the frequencies above the default processor core operating frequency. In other instances, well-known instruction instances, protocols, structures and techniques have not been shown in detail in order not to obfuscate the description.
The description herein uses the terms “job” and “node.” The term “job” refers to a task or tasks performed by a node. Examples of a task include searching a database, updating a record(s) in a database, performing a computation(s), backing up data, compressing data, scanning data, analyzing data, etc. A node can perform a job with a variety of techniques include: executing a program or batch of programs, awakening an executing instance of a program(s) (“process”), passing a parameter(s) to a process, etc. The node may execute programs serially, in parallel, or a combination thereof. Processes may cooperate or coordinate with each other to perform a job or task of a job. The term “node” is used herein to refer to a computational entity within a group or cluster of nodes that can execute a program(s). Examples of a node include a core of a processor, a processor, an application specific integrated circuit, a blade server, etc.
Power management techniques react to current energy usage (e.g., by powering down nodes, scaling down frequencies, etc.) rather than proactively manage power use based on predicted energy usage for performing a job. The predicted energy usage is based on energy usage and performance data collected prior to performing the job. When a job scheduler receives a job, the job scheduler determines whether the requested job (or a similar job) has been previously performed by one or more nodes in a cluster. If the job has been performed previously, the job scheduler (or an entity that can communicate with the job scheduler) retrieves actual energy usage (e.g., watts consumed) and actual job performance data (e.g., time to completion) for the previously performed job. The job scheduler can also retrieve or generate estimated energy usage and/or job performance data at different processor core operating frequencies of a node(s) in the cluster. The job scheduler can analyze the energy usage and job performance data to determine a processor core operating frequency for performing the job while conserving energy. A job criterion, (e.g., a policy that governs the job) may also influence selection of the processor core operating frequency to satisfy the criterion. The job scheduler assigns the job to one or more nodes in the cluster to be performed at the determined processor core operating frequency.
FIG. 1 depicts an example conceptual diagram of a system for selecting frequencies to perform jobs based on energy usage and performance metrics. The system includes a cluster comprising four nodes—node 1 109, node 2 117, node 3 125, and node N 133. The nodes 109, 117, 125, and 133 respectively comprise control processes 111, 119, 127, and 135, and further comprise cores 1 113, 121, 129, and 137, respectively and cores 2 115, 123, 131, and 139, respectively. The cores 1 113, 121, 138 and 137 and cores 2 115, 123, 131, and 139 can operate at multiple processor core operating frequencies. An initial/default processor core operating frequency is specified for the cores 1 113, 121, 138 and 137 and cores 2 115, 123, 131, and 139. For example, oscillators associated with each of the nodes 109, 117, 125, and 133 provide output to control frequency of the cores 1 113, 121, 138 and 137 and cores 2 115, 123, 131. Initially, the frequency is a default processor core operating frequency. The default processor core operating frequency can be divided/multiplied to decrease/increase the frequency (“frequency scaling”) of the cores 1 113, 121, 138 and 137 and cores 2 115, 123, 131, and 139. The frequencies can be varied within a certain operating range of the cores 1 113, 121, 138 and 137 and cores 2 115, 123, 131, and 139 and the division/multiplication of the default processor core operating frequency can be based on a certain factor. For example, the default processor core operating frequency of core 1 113 and core 2 115 is 4 GHz. The core 1 113 and core 2 115 can operate in the range of 2 GHz to 8 GHz. The default processor core operating frequency can be divided/multiplied by factors of 2, so supported frequencies for the core 1 113 and the core 2 115 are 2 GHz, 4 GHz, and 8 GHz. Embodiments are not limited to any of these example illustrations relating to processor core operating frequency. It should be appreciated that a variety of designs exist and are possible for cores, which could affect any one of the operating range, degree of frequency scaling, and mechanism for frequency scaling. For brevity, the description will refer to those frequencies that fall within an operating range of a core(s) or that are in accordance with a specification of a core(s) as “supported frequencies.”
The cluster is associated with a server 101 that manages the cluster. The server 101 is connected to a storage device 105 that hosts a performance and energy usage database 107. The server 101 comprises an energy aware energy aware job scheduler 103 that assigns jobs to the nodes 109, 117, 125, and 133 based on analysis of energy usage and job performance data. The energy aware job scheduler 103 comprises an energy awareness module 102 and a job assignor 104. FIG. 1 depicts the energy aware job scheduler 103 as comprising the distinct modules (e.g., functions, procedures, routines, methods of a class, etc.) for illustrative purposes. Depicting the energy awareness module 102 conceptually illustrates the functionality for analyzing energy usage and job performance data, and selecting a processor core operating frequency accordingly. Depicting the job assignor 104 conceptually illustrates the functionality for assigning jobs to nodes in accordance with the operations/output of the energy awareness module 102. The names of the modules attempt to reflect the illustrated functionality of the modules within the limited space of the drawing sheet, and should not be used to limit embodiments. Embodiments can implement the code for an energy aware job scheduler in accordance with a variety of programming practices, programming styles, programming paradigms, etc. For example, the functionality can range from being more modular (e.g., separate modules retrieve data, analyze data, and select a processor core operating frequency) to not modular (e.g., a single routine/function/procedure performs all functionality). Furthermore, embodiments can implement one or more distinct programs. For example, separate programs can be implemented to analyze job performance and energy usage data and to select a processor core operating frequency. These separate programs can then communicate with a job scheduler to assign jobs in accordance with the analysis and selected processor core operating frequency.
Returning to FIG. 1, the energy aware job scheduler 103 selects one or more nodes to perform the job based on resources (e.g., amount of memory, network bandwidth, etc.) indicated for the job and availability of the nodes. The energy awareness module 102 determines a processor core operating frequency for the selected node(s) based on a job criterion (e.g., maximum run time, deadline for completing the job, etc.) and energy usage and performance data collected during a previous performance of the job. The energy aware job scheduler 103 also determines a processor core operating frequency based on a policy for the system (e.g., a monthly energy consumption policy for the overall system, a daily energy consumption limit per node in the system, etc.). The job assignor module 102 then assigns the job to the node(s). Assignment of a job to a node can be implemented with a variety of techniques. Examples of job assignment techniques include: transmitting an operation code to a listening process, which could be the control process, on the node; transmitting, to a control process on the node, a reference to a program to be executed, instantiating a control process on a management system, which could be the same system hosting the job scheduler, to remotely control a node to perform a job; using a remote procedure call; communicating a command message to a control process on the node; and forwarding a job descriptor to a node to be parsed by a control process on the node. The control processes 111, 119, 127, and 135 can be instances of a module(s) of the energy aware job scheduler 103, and may be locally instantiated. The code for the control processes 111, 119, 127, and 135 may be stored locally also (e.g., installed at each node, distributed from a remote management system, etc.). The control processes 111, 119, 127, and 135 can be utilized to collect energy usage and job performance data while jobs are being performed by the respective nodes 109, 117, 125, and 137. Embodiments can also collect energy usage and job performance data with other processes independent of the job scheduler. The collected energy usage and job performance data is stored in the performance and energy usage database 107. Prior to job assignment, coincident to job assignment, or prior to performing a job, a control process sets the processor core operating frequency to the processor core operating frequency selected by the job scheduler. For instance, the control processes 111, 119, 125, and 135 can utilize an application programming interface (API) to change the processor core operating frequency of the respective cores. Embodiments are not limited to an API, though. Embodiments can execute a proprietary script to adjust the processor core operating frequency, can set a value in hardware that adjusts the processor core operating frequency, etc.
At stage A, the energy aware job scheduler 103 receives a job. For example, the energy aware job scheduler 103 receives a job descriptor file specifying the programs to be executed and the resources that are necessary for the programs to execute. Included in the specified necessary resources may be, for example, an amount of memory, types of processors, storage space, software licenses, etc. A job request can originate from a plethora of sources. A job request may originate from an executing program that accepts information entered into a user interface by a user at a system that may or may not be the system that hosts the job scheduler. A job request may originate from a process that manages a list of job requests scheduled in advance. For example, a system administrator may schedule a backup job and virus scan job every Saturday at 3:00 am with a user interface of a job scheduling application. At 3:00 am on Saturday, a process associated with the scheduling application generates a job request. As another example, a user can enter information for a job request into a web browser interface and submit the information via a web browser. A process of an online service provider processes the information and generates a job request.
At stage B, the energy awareness module 103 accesses the database 107 to determine whether the job has been performed and to retrieve energy usage and job performance data that corresponds to the job. The energy awareness module 103 searches the performance and energy usage database 107 for an indication of the job (e.g., an identifier of the job, a job type or class, etc) responsive to receiving a job request. Inclusion in one or more records in the performance and energy usage database 107 indicates that the job has been previously performed in the cluster associated with the server 101. Embodiments are not limited to searching a database of job performance and energy usage data to determine whether a job has been previously performed. Embodiments can maintain various information in a structure(s) that indicates jobs previously performed including: a structure that indicates jobs performed in the cluster within a preceding time period; a structure that indicates the last n jobs performed; separate structures for different classes of jobs, each indicating the last n jobs of that class performed; etc.
An example record 151 from the database 107 is illustrated in FIG. 1 as indicating a job identifier, nodes that performed the job, job class, and job performance data and energy usage data at three different processor core operating frequencies. The example record 151 indicates a job identifier “Job1”, nodes Node 1 and Node 2 as having performed Job1, and a job class “Security Scan.” The record 151 indicates the three supported processor core operating frequencies as 500 MHz, 1 GHz, and 1.2 GHz. At 500 MHz, the job performance and energy usage data respectively specify 3000 seconds and 70 watts. At 1 GHz, the job performance and energy usage data respectively specify 2100 seconds and 90 watts. At 1.2 GHz, the job performance data and energy usage respectively specify 1800 seconds and 100 watts. Assuming that the requested job identifier is Job1, the energy awareness module 102 determines that the requested job has been performed previously. If the energy awareness module 102 determined that the requested job had not been previously performed by the cluster or had not been previously performed within a window of time, then, in response, the energy awareness module 102 can determine whether a similar job had been performed on the cluster based on the job request. Embodiments can implement a performance and energy usage database with more information, less information, or different information than depicted in the example record 151 of FIG. 1. Additional information can be used to determine a previously performed job as similar to a requested job. For example, the energy awareness module 102 can search the performance and energy database 107 for any one or more of a job type, job class, program names associated with the requested job, performance characteristics of the requested job (e.g., core intensive, memory intensive, I/O intensive, both I/O and core intensive, etc.). Embodiments can set a threshold or criterion for accepting an entry for a previously performed job as similar to the requested job (e.g., a minimum number of programs that match). Further, embodiments are not limited to determining that a job or similar job has been previously performed by a cluster with a performance and energy usage database. Embodiments can access other data, such as a log or job request history of operations, to determine whether a job or similar job has been previously performed.
In response to receiving the job request and determining that the job Job1 has been previously performed (or that Job1 is sufficiently similar to the requested job), the energy awareness module 102 retrieves energy usage and job performance data from the record 151. The energy usage and job performance data can comprise estimates of energy usage and job performance data for one or more of the supported frequencies of the nodes 109, 117. For example, the control processes 111 and 119 can utilize an energy use measuring/monitoring tool, such as the Active Energy Manager from IBM®, to determine the power consumed by the nodes 109 and 117, respectively. The energy awareness module 102 determines aggregate power consumption based on collecting the power consumption from the control processes 109 and 117. The energy awareness module 102 can also computes the completion time from the start time and end time of the job. The energy awareness module 102 can use the power consumption and completion time at 1.2 GHz to estimate power consumption and completion times at 1 GHz and 500 MHz on nodes 109, 117. Embodiments can replace estimated job performance and energy usage data with actual job performance and energy usage data if/when the job is performed at the other frequencies. For example, on a second performance of the job, the energy awareness module 102 selects 500 MHz to perform the job. During the second performance, the energy aware job scheduler 103 can determine actual energy usage and job performance. An energy use monitoring/measuring tool can update the energy usage and job performance data to include the actual energy usage and performance at 500 MHz. The energy awareness module 102 could then use the actual energy usage and job performance data at 500 MHz when selecting a process core operating frequency for future performance of the job.
At stage C, the energy awareness module 102 utilizes the energy usage and performance data to select a frequency to run the job according to a performance policy. The performance policy can be included in a job description file associated with the job. For example, if the performance policy indicates that energy consumption should be minimized without regard to application performance (e.g., completion time), the energy awareness module 102 selects the processor core operating frequency based on the lowest energy usage indicated in the energy usage data. As another example, if the performance policy indicates a minimum performance to be maintained while minimizing energy consumption, the energy awareness module 102 selects the processor core operating frequency associated with the lowest energy usage indicated in the energy usage data that corresponds to a performance indicated in the performance data that is greater than or equal to the specified minimum performance.
At stage D, the job assignor module 104 assigns the job to nodes in the cluster and sets the frequency of the nodes. In this example, the job assignor 104 assigns the job to the nodes 109 and 117 and instructs the control processes 111 and 119 to set the processor core operating frequencies of the cores 1 113 and 121 and cores 2 115 and 123 to the selected processor core operating frequency.
FIGS. 2 and 3 are flowcharts depicting example operations for selecting frequencies to run jobs based on energy usage and performance data. Flow begins at block 201, where a job is received for a cluster. For example, a user submits a job to the cluster using a host system's command line interface by typing a name of an executable file that indicates the job's tasks. As another example, a user submits a job through a management interface provided by the host system. The management interface allows the user to select tasks for the job and indicate task dependencies.
At block 203, it is determined if the job has been performed previously. Determining if the job has been performed previously can comprise searching a performance and energy usage database for a job identifier, searching the performance and energy usage database for similar jobs, etc. In addition, a job scheduler may also determine whether the job was performed within a certain preceding time period. If the job has not been performed previously, flow continues at block 205. If the job has been performed previously, flow continues at block 301 of FIG. 3.
At block 205, the job has not been performed previously, so the job is run at a default processor core operating frequency. The job can be performed at the default processor core operating frequency because At some previous time, benchmark tests are run at the default processor core operating frequency, for example when the cluster was configured. Performance metrics are measured during performance of the job (either a previous performance or the current performance) benchmark tests and compared against performance metrics from the benchmark tests so that an appropriate energy model is chosen for the job based on characteristics of the job. For example, different energy models can be chosen for computation intensive jobs and memory intensive jobs because power and energy usage of memories can be considered in addition to power and energy usage of processors for memory intensive jobs when determining overall power and energy usage. As another example, power and energy usage of network elements (e.g., network adapters, routers, hubs, etc.) could be considered in selecting an energy model for an input/output (I/O) intensive job.
At block 207, performance metrics are measured. Examples of performance metrics include giga-instructions per second (GIPS), memory bandwidth in gigabytes per second (GBS), translation lookaside buffer (TLB) misses, cycles per instruction (CPI), completion time, etc.
At block 209, coefficients of an energy model are determined based on the measured performance metrics. The coefficients can be determined from the performance and energy usage database based on the measured performance metrics of a benchmark test that most closely resembles the job (i.e., the characteristics of the job are similar to the characteristics of the benchmark test). For example, a record indicating the coefficients is located based on matching (within a certain range) benchmark test performance metrics with the job performance metrics.
At block 211, energy usage and performance for each of the supported frequencies is estimated based on the coefficients. For example, the power consumption for each of the supported frequencies are estimated based on Expression 1, below. In Expression 1, p represents estimated power consumption; a, b, and c, represent coefficients; and i=0, . . . , n. The default processor core operating frequency is represented by n while the 0 to n−1 represent supported frequencies below the default processor core operating frequency. GIPS and GBS are example performance metrics discussed at block 207.

pi=ai×GIPS+bi×GBS+ci  Expression 1

Performance for each supported frequency can be estimated based on Expression 2, below. The default processor core operating frequency is represented by fn while the f0 to fn−1 represent supported frequencies below the default processor core operating frequency, where i=0, . . . , n. Ti represents estimated completion time for each supported frequency (fi) and Tn represents the completion time of the job at the default processor core operating frequency (fn). CPIn represents a measured cycles per instruction of the job at fn and CPIi represents an estimated cycles per instruction at each Example performance metrics for Tn and CPIn are discussed at block 207.




  
    
      
        
          T
          i
        
        =
        
          
            
              
                T
                n
              
              ×
              
                f
                n
              
            
            
              f
              i
            
          
          ×
          
            
              CPI
              n
            
            
              CPI
              i
            
          
        
      
    
    
      
        Expression
        ⁢
        
          
        
        ⁢
        2
      
    
  




Cycles per instruction at each supported frequency can be estimated based on Expression 3, below. The default processor core operating frequency is represented by n while the 0 to n−1 represent supported frequencies below the default processor core operating frequency where i=0, . . . , n. TPIn represents transactions per instruction and CPIn represents a measured cycles per instruction at fn, while d, e, and f represent coefficients. TPIn is an example performance metric discussed at block 207.

CPIi=di×CPIn+ei×TPIn+fi  Expression 3

Transactions per instruction at the default processor core operating frequency can be estimated based on Expression 4. The default processor core operating frequency is represented by fn. GBS and CPIn are example performance metrics discussed at block 207, and cache_line_size represents a size of cache lines in an instruction cache.




  
    
      
        
          TPI
          n
        
        =
        
          
            GBS
            ×
            
              CPI
              n
            
          
          
            cache_line
            ⁢
            _size
            ×
            
              f
              n
            
          
        
      
    
    
      
        Expression
        ⁢
        
          
        
        ⁢
        4
      
    
  




Energy usage for each supported frequency can then be estimated based on multiplying the estimated completion times by the power consumptions at each supported frequency.
At block 213, the estimated energy usage and job performance data for each of the supported frequencies is stored with an indication of the corresponding supported frequency. The estimated energy usage and performance can be stored in the performance and energy usage database.
FIG. 3 is a flowchart, which continues from FIG. 2, depicting example operations for selecting frequencies to perform jobs based on energy usage and performance data. Flow continues from block 203 of FIG. 3 at block 301. The job has been performed previously, so it is determined if the job is subject to a policy. The policy can indicate performance and/or energy usage constraints for the job. For example, a policy may indicate that energy consumption should be minimized while keeping performance degradation within an indicated tolerance.
At block 303, energy usage and performance data is determined for the supported frequencies. The energy usage and performance data can be determined from the performance and energy usage database based on an identifier of the job. Estimates for energy usage and performance for each supported frequency were computed and stored for a previous performance of the job, or similar job.
At block 305, it is determined if one of the processor core operating frequencies satisfies the policy. For example, the policy specifies that energy usage should be reduced by 50 percent while completion time of the job should not increase more than 20 percent. The energy aware job scheduler can determine a processor core operating frequency of the supported frequencies with an estimated energy usage below 50 percent and an estimated completion time of less than 20 percent degradation based on the energy usage and performance data. If more than one frequency satisfies the policy, the job scheduler can chose the lowest satisfying frequency. If one of the frequencies satisfies the policy, flow continues at block 307. If none of the frequencies satisfy the policy, flow continues at block 313. Embodiments can also set frequencies across nodes or within nodes at different frequencies that satisfy the policy and reduce energy consumption. For example, a job scheduler can determine that energy consumption can be reduced while satisfying performance requirements with a lower frequency on a first node, a higher frequency on a second node, and both frequencies at a third node. In addition, embodiment can reconcile multiple policies and select processor core operating frequency(ies) to perform a job accordingly. For instance, embodiments can reconcile a job policy that specifies a threshold performance degradation of no more than 20% with a cluster policy that specifies a particular amount of energy consumption within a 24 hour period.
At block 307, the processor core operating frequency of the nodes assigned to the job is set based on the processor core operating frequency that satisfies the policy. For example, the job scheduler transmits instructions to control processes of the nodes that indicate the satisfying processor core operating frequency. In response, the control processes set the nodes to run at the satisfying frequency.
At block 309, the job is performed at the assigned nodes. For example, the job scheduler can perform any one of provide a reference indicating a location of code representing the job (or a task within the job) to the control processes; pass data to the control processes, etc. In response, the control processes initiate performance of the job on the assigned nodes. Actual performance and energy usage can be measured while the job is running The job scheduler can store the actual performance and energy usage in the performance and energy usage database so that the actual performance and energy usage can be used for selecting frequencies for future performances of the job rather than the estimated performance and energy usage. In addition, the job scheduler can utilize an energy model to update estimates of other supported frequencies based on the actual performance and energy usage.
At block 311, the processor core operating frequency of the nodes assigned to the job is returned to the default processor core operating frequency. The frequency is returned to the default so that another job can be assigned to the node. Returning the processor core operating frequency of the nodes to default can comprise transmitting instructions, an opcode, command, flag, etc., to the control processes indicating that the nodes should run at the default processor core operating frequency. Embodiments are not limited to returning a core to the default processor core operating frequency. Embodiments can leave the processor core operating frequency unchanged, set the processor core operating frequency to the lowest processor core operating frequency, etc.
At block 313, the job was not subject to a policy or none of the processor core operating frequencies satisfied the policy, so the job is performed at default processor core operating frequency. Although the job can be performed at the default processor core operating frequency, embodiments are not limited to performing the job at the default processor core operating frequency. If the job was not subject to a policy, the job can be run at any processor core operating frequency. The job scheduler can determine the processor core operating frequency based on current/projected workloads, overall power usage of a cluster, etc. If none of the processor core operating frequencies satisfied the policy, the job may be run at a frequency that best satisfies the policy.
Although embodiments refer to performing jobs at different frequencies, embodiments are not so limited. In some embodiments, other energy reduction techniques (e.g., memory throttling, powering down peripherals associated with the nodes that will not be used for a job, etc.) can be utilized in addition to frequency scaling.
The examples above refer to using estimated data and coefficients of energy models. Estimated energy usage data can be computed based on an energy usage regression model. Coefficients of the regression model can be determined when a cluster is configured. Energy usage and performance metrics can be measured while a set of benchmarks is run on nodes in the cluster. The coefficients can be determined based on the measured energy usage and performance metrics. FIG. 4 is a flowchart depicting example operations for determining coefficients of a regression model. Flow begins at block 401, where nodes in a cluster are determined. The nodes in the cluster can be determined during configuration of the cluster.
At block 403, a loop begins for each node.
At block 405, a loop begins for each supported frequency of the node.
At block 407, benchmark tests are run on the node. To run the benchmark tests, a job scheduler can indicate the benchmark tests (e.g., by providing references to the benchmark tests) and the frequency to a control process associated with the node. In response, the control process can initiate execution of the benchmark tests at the indicated processor core operating frequency. The benchmark tests can be based on application workloads defined in Standard Performance Evaluation Corporation (SPEC) CFP2006 benchmarks. The benchmark tests can be based on representative workloads (e.g., computation intensive, memory intensive, I/O intensive, etc.).
At block 409, it is determined if the node is running at default processor core operating frequency. Performance metrics can be measured at the default processor core operating frequency and can be different for different types of workloads (i.e., memory intensive versus computation intensive). The performance metrics measured during benchmark testing can be matched to measured performance metrics for a job the first time the job is performed so that energy usage and performance can be estimated with an appropriate model based on the job's workload (i.e., the job is matched to one of the benchmark tests that most closely resembles the workload of the job). If the node is running at default processor core operating frequency, flow continues at block 411. If the node is not running at default processor core operating frequency, flow continues at block 415.
At block 411, the node is running at default processor core operating frequency, so performance is measured. Examples of performance metrics include giga-instructions per second (GIPS), memory bandwidth in gigabytes per second (GBS), translation lookaside buffer (TLB) misses, cycles per instruction (CPI), completion time, etc.
At block 413, the performance metrics are stored. The performance metrics can be stored in a performance and energy usage database.
At block 415, power consumption and CPI are measured. The power consumption and CPI can be measured at all supported frequencies, less than all supported frequencies, randomly selected supported frequencies, preselected supported frequencies, etc. Power consumption can be measured by AEM. The power consumption can include power consumed by peripherals (e.g., cooling systems, storage devices, etc.) associated with the node. CPI can be determined based on an average number of cycles used for each instruction executed during the benchmark tests.
At block 417, the power consumption is stored with an indication of the frequency in the performance and energy usage database.
At block 419, the loop for each supported frequency ends.
At block 421, coefficients of the energy model are computed based on the power consumption and performance metrics. Coefficients can be computed for each supported frequency based on Expressions 1 and 3. In Expressions 1 and 3, the default processor core operating frequency is represented by n while 0 to n−1 represent supported frequencies below the default processor core operating frequency, where i=0, . . . , n. In Expression 1, p represents measured power consumption at each supported frequency, i. In Expression 3, CPIi represents measured cycles per instruction at each supported frequency, i. TPIn can be computed based on Expression 4. The coefficients are represented by a, b, c, d, and e, GIPS and GBS are performance metrics measured in block 413, and cache_line_size represents a size of cache lines in an instruction cache.




  
    
      
        
          p
          i
        
        =
        
          
            
              a
              i
            
            ×
            GIPS
          
          +
          
            
              b
              i
            
            ×
            GBS
          
          +
          
            
              c
              i
            
            ⁢
            
              

            
            (
            restated
            )
          
        
      
    
    
      
        Expression
        ⁢
        
          
        
        ⁢
        1
      
    
  
  
    
      
        
          CPI
          i
        
        =
        
          
            
              d
              i
            
            ×
            
              CPI
              n
            
          
          +
          
            
              e
              i
            
            ×
            
              TPI
              n
            
          
          +
          
            
              f
              i
            
            ⁢
            
              

            
            (
            restated
            )
          
        
      
    
    
      
        Expression
        ⁢
        
          
        
        ⁢
        3
      
    
  
  
    
      
        
          
            TPI
            n
          
          =
          
            
              GBS
              ×
              
                CPI
                n
              
            
            
              cache_line
              ⁢
              _size
              ×
              
                f
                n
              
            
          
        
        ⁢
        
          

        
        ⁢
        
          (
          restated
          )
        
      
    
    
      
        Expression
        ⁢
        
          
        
        ⁢
        4
      
    
  




At block 423, the coefficients are stored. The coefficients can be stored with an indication of the performance metrics. When a job is performed, performance metrics can be measured and matched to performance metrics measured during benchmark testing in the performance and energy usage database so that appropriate coefficients can be located in the database and utilized when estimating performance and energy usage of the job.
At block 425, the loop for each node ends.
Embodiments are not limited to the example flowcharts depicted in the above figures. Embodiments can perform additional operations, fewer operations, operations in parallel, etc. For instance, referring to FIG. 4, the operations for running benchmark tests and measuring performance metrics and power consumption for each node can be run in parallel. In addition, operations can be performed to select energy usage and performance data for a previous run of a job and similar jobs. A job scheduler can use data from a previous run of the job at a first set of frequencies and data from similar previously run jobs at other supported frequencies. Operations can also be performed to compare data of different types of nodes, which support different frequencies, when selecting a node for job scheduling.
As will be appreciated by one skilled in the art, aspects of the present inventive subject matter may be embodied as a system, method or computer program product. Accordingly, aspects of the present inventive subject matter may take the form of an entirely hardware embodiment, a software embodiment (including firmware, resident software, micro-code, etc.) or an embodiment combining software and hardware aspects that may all generally be referred to herein as a “circuit,” “module” or “system.” Furthermore, aspects of the present inventive subject matter may take the form of a computer program product embodied in one or more computer readable medium(s) having computer readable program code embodied thereon.
Any combination of one or more computer readable medium(s) may be utilized. The computer readable medium may be a computer readable signal medium or a computer readable storage medium. A computer readable storage medium may be, for example, but not limited to, an electronic, magnetic, optical, electromagnetic, infrared, or semiconductor system, apparatus, or device, or any suitable combination of the foregoing. More specific examples (a non-exhaustive list) of the computer readable storage medium would include the following: an electrical connection having one or more wires, a portable computer diskette, a hard disk, a random access memory (RAM), a read-only memory (ROM), an erasable programmable read-only memory (EPROM or Flash memory), an optical fiber, a portable compact disc read-only memory (CD-ROM), an optical storage device, a magnetic storage device, or any suitable combination of the foregoing. In the context of this document, a computer readable storage medium may be any tangible medium that can contain, or store a program for use by or in connection with an instruction execution system, apparatus, or device.
A computer readable signal medium may include a propagated data signal with computer readable program code embodied therein, for example, in baseband or as part of a carrier wave. Such a propagated signal may take any of a variety of forms, including, but not limited to, electro-magnetic, optical, or any suitable combination thereof. A computer readable signal medium may be any computer readable medium that is not a computer readable storage medium and that can communicate, propagate, or transport a program for use by or in connection with an instruction execution system, apparatus, or device.
Program code embodied on a computer readable medium may be transmitted using any appropriate medium, including but not limited to wireless, wireline, optical fiber cable, RF, etc., or any suitable combination of the foregoing.
Computer program code for carrying out operations for aspects of the present inventive subject matter may be written in any combination of one or more programming languages, including an object oriented programming language such as Java, Smalltalk, C++ or the like and conventional procedural programming languages, such as the “C” programming language or similar programming languages. The program code may execute entirely on the user's computer, partly on the user's computer, as a stand-alone software package, partly on the user's computer and partly on a remote computer or entirely on the remote computer or server. In the latter scenario, the remote computer may be connected to the user's computer through any type of network, including a local area network (LAN) or a wide area network (WAN), or the connection may be made to an external computer (for example, through the Internet using an Internet Service Provider).
Aspects of the present inventive subject matter are described with reference to flowchart illustrations and/or block diagrams of methods, apparatus (systems) and computer program products according to embodiments of the inventive subject matter. It will be understood that each block of the flowchart illustrations and/or block diagrams, and combinations of blocks in the flowchart illustrations and/or block diagrams, can be implemented by computer program instructions. These computer program instructions may be provided to a processor of a general purpose computer, special purpose computer, or other programmable data processing apparatus to produce a machine, such that the instructions, which execute via the processor of the computer or other programmable data processing apparatus, create means for implementing the functions/acts specified in the flowchart and/or block diagram block or blocks.
These computer program instructions may also be stored in a computer readable medium that can direct a computer, other programmable data processing apparatus, or other devices to function in a particular manner, such that the instructions stored in the computer readable medium produce an article of manufacture including instructions which implement the function/act specified in the flowchart and/or block diagram block or blocks.
The computer program instructions may also be loaded onto a computer, other programmable data processing apparatus, or other devices to cause a series of operational steps to be performed on the computer, other programmable apparatus or other devices to produce a computer implemented process such that the instructions which execute on the computer or other programmable apparatus provide processes for implementing the functions/acts specified in the flowchart and/or block diagram block or blocks.
FIG. 5 depicts an example computer system with an energy aware job scheduler. A computer system includes a processor unit 501 (possibly including multiple processors, multiple cores, multiple nodes, and/or implementing multi-threading, etc.). The computer system includes memory 507. The memory 507 may be system memory (e.g., one or more of cache, SRAM, DRAM, zero capacitor RAM, Twin Transistor RAM, eDRAM, EDO RAM, DDR RAM, EEPROM, NRAM, RRAM, SONOS, PRAM, etc.) or any one or more of the above already described possible realizations of machine-readable media. The computer system also includes a bus 503 (e.g., PCI bus, ISA bus, PCI-Express bus, HyperTransport® bus, InfiniBand® bus, NuBus bus, etc.), a network interface 505 (e.g., an ATM interface, an Ethernet interface, a Frame Relay interface, SONET interface, wireless interface, etc.), and a storage device(s) 509 (e.g., optical storage, magnetic storage, etc.). The computer system also includes an energy aware job scheduler 521. The energy aware job scheduler 521 analyzes energy usage and job performance data to select a processor core operating frequency to perform a job on a node in a cluster in accordance with a policy for the job. Any one of these functionalities may be partially (or entirely) implemented in hardware and/or on the processing unit 501. For example, the functionality may be implemented with an application specific integrated circuit, in logic implemented in the processing unit 501, in a co-processor on a peripheral device or card, etc. Further, realizations may include fewer or additional components not illustrated in FIG. 5 (e.g., video cards, audio cards, additional network interfaces, peripheral devices, etc.). The processor unit 501, the storage device(s) 509, and the network interface 505 are coupled to the bus 503. Although illustrated as being coupled to the bus 503, the memory 507 may be coupled to the processor unit 501.
While the embodiments are described with reference to various implementations and exploitations, it will be understood that these embodiments are illustrative and that the scope of the inventive subject matter is not limited to them. For instance, the above examples refer to determining whether a job or similar job has been previously performed in a cluster. Embodiments can, however, utilize energy and usage data for the job or a similar job performed in a different cluster or a node not within a cluster. Embodiments can access energy usage and job performance data independent of the cluster and utilize this data, perhaps based on node similarity, to perform the requested job. In general, techniques for energy-aware job scheduling as described herein may be implemented with facilities consistent with any hardware system or hardware systems. Many variations, modifications, additions, and improvements are possible.
Plural instances may be provided for components, operations or structures described herein as a single instance. Finally, boundaries between various components, operations and data stores are somewhat arbitrary, and particular operations are illustrated in the context of specific illustrative configurations. Other allocations of functionality are envisioned and may fall within the scope of the inventive subject matter. In general, structures and functionality presented as separate components in the exemplary configurations may be implemented as a combined structure or component. Similarly, structures and functionality presented as a single component may be implemented as separate components. These and other variations, modifications, additions, and improvements may fall within the scope of the inventive subject matter.

## Claims

1. A method comprising:
accessing data that specifies energy usage and job performance metrics that correspond to a job and a plurality of processor core operating frequencies, wherein the job has been requested of a cluster;
selecting a first of the plurality of processor core operating frequencies that satisfies an energy usage criterion for performing the job based, at least in part, on the data that specifies energy usage and job performance metrics that correspond to the job,
wherein the plurality of processor core operating frequencies comprises a default processor core operating frequencies, and wherein the first of the plurality of processor core operating frequencies is lower than the default processor core operating frequency;
determining coefficients of an energy model based on previously collected performance metrics and energy usage for the job performed in the cluster at the default processor core operating frequency;
estimating energy usage and performance metrics for the job at the first of the plurality of processor core operating frequencies based on the coefficients and the energy model;
storing the estimated energy usage and performance metrics for the job at the first of the plurality of processor core operating frequencies; and
associating the stored estimated energy usage and performance metrics with the job and with the first of the plurality of processor core operating frequencies; and
assigning the job to be performed by a node in the cluster at the selected first of the plurality of processor core operating frequencies.

2. The method of claim 1 further comprising determining that the job or a similar job has previously been performed.

3. The method of claim 1, wherein the energy usage criterion for performing the job indicates at least one of a maximum amount of energy to be used to perform the job and an energy conservation goal.

4. The method of claim 1, wherein said assigning the job to be performed by the node in the cluster at the first of the plurality of processor core operating frequencies comprises:
setting at least a first processor core of the node to run at the first of the plurality of processor core operating frequencies.

5. The method of claim 1 further comprising:
prior to said selecting the first of the plurality of processor core operating frequencies that satisfies the energy usage criterion for performing the job, collecting the energy usage and performance metrics for the job performed in the cluster at the default processor core operating frequency.

6. The method of claim 1 further comprising:
determining that a performance constraint is specified for the job; wherein said selecting the first of the plurality of processor core operating frequencies that also satisfies the performance constraint.

7. The method of claim 1 further comprising:
measuring actual energy usage and performance metrics while the job is performed by the node at the first of the plurality of processor core operating frequencies; and
updating the data with the actual energy usage and performance metrics.