move thread.interrupt call, get rid of prinln call

zendesk · Apr 27, 2015 · 3b6195b · 3b6195b
1 parent cfc3731
commit 3b6195b
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/src/main/java/com/zendesk/maxwell/schema/SchemaPosition.java b/src/main/java/com/zendesk/maxwell/schema/SchemaPosition.java
@@ -101,11 +101,10 @@ public void set(BinlogPosition p) {
 	public void setSync(BinlogPosition p) {
 		LOGGER.debug("syncing binlog position: " + p);
 		position.set(p);
-		thread.interrupt();
 		while ( true ) {
+			thread.interrupt();
 			BinlogPosition s = storedPosition.get();
 			if ( p.newerThan(s) ) {
-				System.out.println("sleeping, waiting... ");
 				try { Thread.sleep(50); } catch (InterruptedException e) { }
 			} else {
 				break;