From 900d74fe5a99d77dd90139394c326b040233b211 Mon Sep 17 00:00:00 2001
From: Jinyang Li <jinyangli34@gmail.com>
Date: Wed, 18 Sep 2024 13:16:31 -0700
Subject: [PATCH] Fix toConnectorSession conversion in BeginTableExecuteResult

---
 .../src/main/java/io/trino/metadata/MetadataManager.java        | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/core/trino-main/src/main/java/io/trino/metadata/MetadataManager.java b/core/trino-main/src/main/java/io/trino/metadata/MetadataManager.java
index cfbc4cf532a6..9cfabd417d76 100644
--- a/core/trino-main/src/main/java/io/trino/metadata/MetadataManager.java
+++ b/core/trino-main/src/main/java/io/trino/metadata/MetadataManager.java
@@ -339,7 +339,7 @@ public BeginTableExecuteResult<TableExecuteHandle, TableHandle> beginTableExecut
         CatalogHandle catalogHandle = tableExecuteHandle.catalogHandle();
         CatalogMetadata catalogMetadata = getCatalogMetadataForWrite(session, catalogHandle);
         ConnectorMetadata metadata = catalogMetadata.getMetadata(session);
-        BeginTableExecuteResult<ConnectorTableExecuteHandle, ConnectorTableHandle> connectorBeginResult = metadata.beginTableExecute(session.toConnectorSession(), tableExecuteHandle.connectorHandle(), sourceHandle.connectorHandle());
+        BeginTableExecuteResult<ConnectorTableExecuteHandle, ConnectorTableHandle> connectorBeginResult = metadata.beginTableExecute(session.toConnectorSession(catalogHandle), tableExecuteHandle.connectorHandle(), sourceHandle.connectorHandle());
 
         return new BeginTableExecuteResult<>(
                 tableExecuteHandle.withConnectorHandle(connectorBeginResult.getTableExecuteHandle()),