Flaky test: TestZkLocalApplicationRunner testRollingUpgradeOfStreamApplicationsShouldGenerateSameJobModel

testRollingUpgradeOfStreamApplicationsShouldGenerateSameJobModel FAILED  java.lang.AssertionError: expected:<2> but was:<3>  at org.junit.Assert.fail(Assert.java:88)  at org.junit.Assert.failNotEquals(Assert.java:834)  at org.junit.Assert.assertEquals(Assert.java:645)  at org.junit.Assert.assertEquals(Assert.java:631)  at org.apache.samza.test.processor.TestZkLocalApplicationRunner.testRollingUpgradeOfStreamApplicationsShouldGenerateSameJobModel(TestZkLocalApplicationRunner.java:573)