From 06dc2e0174e67f4601efa9e1772ed292de914f3f Mon Sep 17 00:00:00 2001 From: Oleg Avdeev Date: Fri, 15 Jan 2021 19:18:34 -0800 Subject: [PATCH] use SEND_INTERRUPT Signed-off-by: Oleg Avdeev --- sdk/python/feast/pyspark/launchers/aws/emr_utils.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sdk/python/feast/pyspark/launchers/aws/emr_utils.py b/sdk/python/feast/pyspark/launchers/aws/emr_utils.py index 0b8c2b2c6d..49806b4a08 100644 --- a/sdk/python/feast/pyspark/launchers/aws/emr_utils.py +++ b/sdk/python/feast/pyspark/launchers/aws/emr_utils.py @@ -290,7 +290,7 @@ def _cancel_job(emr_client, job: EmrJobRef): emr_client.cancel_steps( ClusterId=job.cluster_id, StepIds=[step_id], - StepCancellationOption="TERMINATE_PROCESS", + StepCancellationOption="SEND_INTERRUPT", ) _wait_for_job_state(