Use c3.2xlarge instance for EMR hourly traffic log processing.

This commit is contained in:
Brian Simpson
2015-02-18 00:48:44 -05:00
parent bc73cef822
commit bb07898dcf

View File

@@ -51,7 +51,7 @@ class TrafficBase(EmrJob):
BOOTSTRAP_NAME = 'traffic binaries'
BOOTSTRAP_SCRIPT = os.path.join(g.TRAFFIC_SRC_DIR, 'traffic_bootstrap.sh')
_defaults = dict(master_instance_type='m1.small',
slave_instance_type='m3.xlarge', num_slaves=1)
slave_instance_type='c3.2xlarge', num_slaves=1)
def __init__(self, emr_connection, jobflow_name, steps=None, **kw):
combined_kw = copy(self._defaults)