diff --git a/core/trino-spi/src/main/java/io/trino/spi/connector/ConnectorRecordSetProvider.java b/core/trino-spi/src/main/java/io/trino/spi/connector/ConnectorRecordSetProvider.java
index 73d3980f6641..1b63b5edda17 100644
--- a/core/trino-spi/src/main/java/io/trino/spi/connector/ConnectorRecordSetProvider.java
+++ b/core/trino-spi/src/main/java/io/trino/spi/connector/ConnectorRecordSetProvider.java
@@ -23,16 +23,6 @@ default RecordSet getRecordSet(
             ConnectorSplit split,
             ConnectorTableHandle table,
             List<? extends ColumnHandle> columns)
-    {
-        return getRecordSet(transaction, session, split, columns);
-    }
-
-    @Deprecated
-    default RecordSet getRecordSet(
-            ConnectorTransactionHandle transactionHandle,
-            ConnectorSession session,
-            ConnectorSplit split,
-            List<? extends ColumnHandle> columns)
     {
         throw new UnsupportedOperationException("getRecordSet() must be implemented");
     }
diff --git a/lib/trino-plugin-toolkit/src/main/java/io/trino/plugin/base/classloader/ClassLoaderSafeConnectorRecordSetProvider.java b/lib/trino-plugin-toolkit/src/main/java/io/trino/plugin/base/classloader/ClassLoaderSafeConnectorRecordSetProvider.java
index da66239f7d30..c182273a28d0 100644
--- a/lib/trino-plugin-toolkit/src/main/java/io/trino/plugin/base/classloader/ClassLoaderSafeConnectorRecordSetProvider.java
+++ b/lib/trino-plugin-toolkit/src/main/java/io/trino/plugin/base/classloader/ClassLoaderSafeConnectorRecordSetProvider.java
@@ -49,12 +49,4 @@ public RecordSet getRecordSet(ConnectorTransactionHandle transaction, ConnectorS
             return new ClassLoaderSafeRecordSet(delegate.getRecordSet(transaction, session, split, table, columns), classLoader);
         }
     }
-
-    @Override
-    public RecordSet getRecordSet(ConnectorTransactionHandle transactionHandle, ConnectorSession session, ConnectorSplit split, List<? extends ColumnHandle> columns)
-    {
-        try (ThreadContextClassLoader ignored = new ThreadContextClassLoader(classLoader)) {
-            return new ClassLoaderSafeRecordSet(delegate.getRecordSet(transactionHandle, session, split, columns), classLoader);
-        }
-    }
 }
diff --git a/plugin/trino-kinesis/src/main/java/io/trino/plugin/kinesis/KinesisRecordSetProvider.java b/plugin/trino-kinesis/src/main/java/io/trino/plugin/kinesis/KinesisRecordSetProvider.java
index e92c7ef7692c..02893125e275 100644
--- a/plugin/trino-kinesis/src/main/java/io/trino/plugin/kinesis/KinesisRecordSetProvider.java
+++ b/plugin/trino-kinesis/src/main/java/io/trino/plugin/kinesis/KinesisRecordSetProvider.java
@@ -21,6 +21,7 @@
 import io.trino.spi.connector.ConnectorRecordSetProvider;
 import io.trino.spi.connector.ConnectorSession;
 import io.trino.spi.connector.ConnectorSplit;
+import io.trino.spi.connector.ConnectorTableHandle;
 import io.trino.spi.connector.ConnectorTransactionHandle;
 import io.trino.spi.connector.RecordSet;
 
@@ -54,6 +55,7 @@ public RecordSet getRecordSet(
             ConnectorTransactionHandle transactionHandle,
             ConnectorSession session,
             ConnectorSplit split,
+            ConnectorTableHandle table,
             List<? extends ColumnHandle> columns)
     {
         KinesisSplit kinesisSplit = (KinesisSplit) split;