From 4071ae2bf0582880e6f051296c0fdc875368ab32 Mon Sep 17 00:00:00 2001
From: Holden Karau <hkarau@apple.com>
Date: Fri, 24 Apr 2020 15:21:30 -0700
Subject: [PATCH] Python style fix

---
 .../kubernetes/integration-tests/tests/decommissioning.py   | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/resource-managers/kubernetes/integration-tests/tests/decommissioning.py b/resource-managers/kubernetes/integration-tests/tests/decommissioning.py
index 9d9b0c4261886..84dc514b8988b 100644
--- a/resource-managers/kubernetes/integration-tests/tests/decommissioning.py
+++ b/resource-managers/kubernetes/integration-tests/tests/decommissioning.py
@@ -32,15 +32,17 @@
         .getOrCreate()
     sc = spark._sc
     acc = sc.accumulator(0)
+
     def addToAcc(x):
         acc.add(1)
         return x
+
     initialRdd = sc.parallelize(range(100), 5)
     accRdd = initialRdd.map(addToAcc)
     # Trigger a shuffle so there are shuffle blocks to migrate
     rdd = accRdd.map(lambda x: (x, x)).groupByKey()
     rdd.collect()
-    print("1st accumulator value is: "+ str(acc.value))
+    print("1st accumulator value is: " + str(acc.value))
     print("Waiting to give nodes time to finish migration, decom exec 1.")
     print("...")
     time.sleep(5)
@@ -51,7 +53,7 @@ def addToAcc(x):
     print("Executor node should be deleted now")
     rdd.count()
     rdd.collect()
-    print("Final accumulator value is: "+ str(acc.value))
+    print("Final accumulator value is: " + str(acc.value))
     print("Finished waiting, stopping Spark.")
     spark.stop()
     print("Done, exiting Python")