From 772977f391d97fc7fa83ad2245f9d9285a3df832 Mon Sep 17 00:00:00 2001
From: Randall Hauch <rhauch@gmail.com>
Date: Mon, 25 Jan 2016 13:50:17 -0600
Subject: [PATCH] Attempted to correct Travis build error

---
 .../src/main/java/io/debezium/relational/Tables.java         | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git a/debezium-core/src/main/java/io/debezium/relational/Tables.java b/debezium-core/src/main/java/io/debezium/relational/Tables.java
index 3ded2e0b0..020bf8ff7 100644
--- a/debezium-core/src/main/java/io/debezium/relational/Tables.java
+++ b/debezium-core/src/main/java/io/debezium/relational/Tables.java
@@ -6,7 +6,6 @@
 package io.debezium.relational;
 
 import java.util.ArrayList;
-import java.util.Collections;
 import java.util.HashMap;
 import java.util.HashSet;
 import java.util.List;
@@ -86,7 +85,7 @@ public int size() {
 
     public Set<TableId> drainChanges() {
         return lock.write(() -> {
-            if (changes.isEmpty()) return Collections.<TableId>emptySet();
+            // if (changes.isEmpty()) return Collections.<TableId>emptySet();
             Set<TableId> result = new HashSet<>(changes);
             changes.clear();
             return result;
@@ -306,7 +305,7 @@ public String toString() {
         return lock.read(() -> {
             StringBuilder sb = new StringBuilder();
             sb.append("Tables {").append(System.lineSeparator());
-            tablesByTableId.forEach((tableId,table)->{
+            tablesByTableId.forEach((tableId, table) -> {
                 sb.append("  ").append(tableId).append(": {").append(System.lineSeparator());
                 table.toString(sb, "    ");
                 sb.append("  }").append(System.lineSeparator());