From 066f435fe742eca55de9a5d0ae86973b1649cdfe Mon Sep 17 00:00:00 2001 From: ksindi Date: Tue, 24 Jan 2017 16:59:54 -0500 Subject: [PATCH] BUG fix logging of cluster --- sparksteps/__main__.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sparksteps/__main__.py b/sparksteps/__main__.py index 51bb012..0c29149 100644 --- a/sparksteps/__main__.py +++ b/sparksteps/__main__.py @@ -121,7 +121,7 @@ def main(): cluster_config = cluster.emr_config(**args_dict) response = client.run_job_flow(**cluster_config) cluster_id = response['JobFlowId'] - logger.info("Cluster ID: ", cluster_id) + logger.info("Cluster ID: %s", cluster_id) emr_steps = steps.setup_steps(s3, args.s3_bucket,