[samza] branch master updated: [Tests] Fix TestZkLocalApplicationRunner (#1563)

[cameronlee]

This is an automated email from the ASF dual-hosted git repository.

cameronlee pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/samza.git


The following commit(s) were added to refs/heads/master by this push:
     new 5714ff9  [Tests] Fix TestZkLocalApplicationRunner (#1563)
5714ff9 is described below

commit 5714ff98bce0391b323a2e0b5723d7da53deb558
Author: jia-gao <94939653+jia-...@users.noreply.github.com>
AuthorDate: Mon Dec 6 14:53:24 2021 -0800

    [Tests] Fix TestZkLocalApplicationRunner (#1563)
    
    Co-authored-by: Jiazhou Gao (jia-gao)
---
 .../apache/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 e2e599d..33c5a65 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 class TestZkLocalApplicationRunner extends 
IntegrationTestHarness {
     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);
   }
 
   /**