From 3413698ae3da7fcfffc023bb9782aece7a5fa61e Mon Sep 17 00:00:00 2001
From: Jiazhou Gao <jiagao@jiagao-mn1.linkedin.biz>
Date: Tue, 23 Nov 2021 16:09:25 -0800
Subject: [PATCH] Fix TestZkLocalApplicationRunner

---
 .../samza/test/processor/TestZkLocalApplicationRunner.java  | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/samza-test/src/test/java/org/apache/samza/test/processor/TestZkLocalApplicationRunner.java b/samza-test/src/test/java/org/apache/samza/test/processor/TestZkLocalApplicationRunner.java
index e2e599da3d..33c5a65fd5 100644
--- a/samza-test/src/test/java/org/apache/samza/test/processor/TestZkLocalApplicationRunner.java
+++ b/samza-test/src/test/java/org/apache/samza/test/processor/TestZkLocalApplicationRunner.java
@@ -319,12 +319,12 @@ public void shouldStopNewProcessorsJoiningGroupWhenNumContainersIsGreaterThanNum
     assertEquals(previousJobModel[0], updatedJobModel);
     assertEquals(new MapConfig(), updatedJobModel.getConfig());
     assertEquals(NUM_KAFKA_EVENTS, processedMessagesLatch.getCount());
-    appRunner1.kill();
-    appRunner1.waitForFinish();
     appRunner2.kill();
     appRunner2.waitForFinish();
-    assertEquals(appRunner1.status(), ApplicationStatus.SuccessfulFinish);
     assertEquals(appRunner2.status(), ApplicationStatus.UnsuccessfulFinish);
+    appRunner1.kill();
+    appRunner1.waitForFinish();
+    assertEquals(appRunner1.status(), ApplicationStatus.SuccessfulFinish);
   }
 
   /**