prevent MaxwellBootstrapUtility from hanging if rowCount is decreased

Nicolas Maquet · Nicolas Maquet · commit 71ce27db39a1 · 2015-12-22T10:27:22.000+13:00
diff --git a/src/main/java/com/zendesk/maxwell/bootstrap/MaxwellBootstrapUtility.java b/src/main/java/com/zendesk/maxwell/bootstrap/MaxwellBootstrapUtility.java
@@ -36,9 +36,8 @@ private void run(String[] argv) throws Exception {
 						startedTimeMillis = System.currentTimeMillis();
 					}
 				 	insertedRowsCount = getInsertedRowsCount(connection, rowId);
-				} else {
-					isComplete = getIsComplete(connection, rowId);
 				}
+				isComplete = getIsComplete(connection, rowId);
 				displayProgress(rowCount, insertedRowsCount, startedTimeMillis);
 				Thread.sleep(UPDATE_PERIOD_MILLIS);
 			}

Original file line number	Diff line number	Diff line change
`@@ -36,9 +36,8 @@ private void run(String[] argv) throws Exception {`
`36`	`36`	`startedTimeMillis = System.currentTimeMillis();`
`37`	`37`	`}`
`38`	`38`	`insertedRowsCount = getInsertedRowsCount(connection, rowId);`
`39`		`- } else {`
`40`		`- isComplete = getIsComplete(connection, rowId);`
`41`	`39`	`}`
	`40`	`+ isComplete = getIsComplete(connection, rowId);`
`42`	`41`	`displayProgress(rowCount, insertedRowsCount, startedTimeMillis);`
`43`	`42`	`Thread.sleep(UPDATE_PERIOD_MILLIS);`
`44`	`43`	`}`