fix COMMIT string equality

zendesk · Sep 3, 2015 · 5ad6f5c · 5ad6f5c
1 parent c63c8f0
commit 5ad6f5c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/com/zendesk/maxwell/MaxwellParser.java b/src/main/java/com/zendesk/maxwell/MaxwellParser.java
@@ -188,7 +188,7 @@ private LinkedList<MaxwellAbstractRowsEvent> getTransactionEvents() throws Excep
 				case MySQLConstants.QUERY_EVENT:
 					QueryEvent qe = (QueryEvent) v4Event;
 
-					if ( qe.getSql().toString() == "COMMIT" ) {
+					if ( qe.getSql().toString().equals("COMMIT") ) {
 						// some storage engines(?) will output a "COMMIT" QUERY_EVENT instead of a XID_EVENT.
 						// not sure exactly how to trigger this.
 						if ( !list.isEmpty() )