From 26e4d4c9a5cff56ec27158e311825408c62a72a7 Mon Sep 17 00:00:00 2001
From: dnwick <dnsnipe123@gmail.com>
Date: Fri, 2 Apr 2021 16:02:25 +0530
Subject: [PATCH] Reverting the fix due to test failures

---
 .../polling/strategies/WaitOnMissingRecordPollingStrategy.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/component/src/main/java/io/siddhi/extension/io/cdc/source/polling/strategies/WaitOnMissingRecordPollingStrategy.java b/component/src/main/java/io/siddhi/extension/io/cdc/source/polling/strategies/WaitOnMissingRecordPollingStrategy.java
index 7426e78..4565173 100644
--- a/component/src/main/java/io/siddhi/extension/io/cdc/source/polling/strategies/WaitOnMissingRecordPollingStrategy.java
+++ b/component/src/main/java/io/siddhi/extension/io/cdc/source/polling/strategies/WaitOnMissingRecordPollingStrategy.java
@@ -157,7 +157,7 @@ public void poll() {
                     }
                     log.error(buildError("Error occurred while processing records in table %s.", tableName), e);
                 } finally {
-                    CDCPollingUtil.cleanupConnection(resultSet, statement, null);
+                    CDCPollingUtil.cleanupConnection(resultSet, null, null);
                 }
                 try {
                     if (metrics != null) {