From 5ad6f5c7d5402ed57c6bdfb7f6dc4b3a07ce5807 Mon Sep 17 00:00:00 2001
From: Ben Osheroff <ben@zendesk.com>
Date: Thu, 3 Sep 2015 13:41:51 -0700
Subject: [PATCH] fix COMMIT string equality

---
 src/main/java/com/zendesk/maxwell/MaxwellParser.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/main/java/com/zendesk/maxwell/MaxwellParser.java b/src/main/java/com/zendesk/maxwell/MaxwellParser.java
index 3c71d953e..5cae5c4d0 100644
--- 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() )