From 05e2dcf780a9b23959b27beac24c5032b453e3ad Mon Sep 17 00:00:00 2001 From: Denodo Research Labs Date: Thu, 6 Jun 2024 17:01:18 +0200 Subject: [PATCH] Pass full session to avoid Unknown connector errors --- .../presto/connector/system/jdbc/ColumnJdbcTable.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/presto-main/src/main/java/com/facebook/presto/connector/system/jdbc/ColumnJdbcTable.java b/presto-main/src/main/java/com/facebook/presto/connector/system/jdbc/ColumnJdbcTable.java index 7de189222147a..afd30c1cc3218 100644 --- a/presto-main/src/main/java/com/facebook/presto/connector/system/jdbc/ColumnJdbcTable.java +++ b/presto-main/src/main/java/com/facebook/presto/connector/system/jdbc/ColumnJdbcTable.java @@ -13,6 +13,7 @@ */ package com.facebook.presto.connector.system.jdbc; +import com.facebook.presto.FullConnectorSession; import com.facebook.presto.Session; import com.facebook.presto.common.predicate.TupleDomain; import com.facebook.presto.common.type.ArrayType; @@ -56,7 +57,6 @@ import static com.facebook.presto.common.type.VarbinaryType.VARBINARY; import static com.facebook.presto.common.type.VarcharType.createUnboundedVarcharType; import static com.facebook.presto.common.type.Varchars.isVarcharType; -import static com.facebook.presto.connector.system.SystemConnectorSessionUtil.toSession; import static com.facebook.presto.connector.system.jdbc.FilterUtil.filter; import static com.facebook.presto.connector.system.jdbc.FilterUtil.stringFilter; import static com.facebook.presto.metadata.MetadataListing.listCatalogs; @@ -115,7 +115,7 @@ public ConnectorTableMetadata getTableMetadata() @Override public RecordCursor cursor(ConnectorTransactionHandle transactionHandle, ConnectorSession connectorSession, TupleDomain constraint) { - Session session = toSession(transactionHandle, connectorSession); + Session session = ((FullConnectorSession) connectorSession).getSession(); Optional catalogFilter = stringFilter(constraint, 0); Optional schemaFilter = stringFilter(constraint, 1); Optional tableFilter = stringFilter(constraint, 2);