This is an automated email from the ASF dual-hosted git repository.

jshao pushed a commit to branch branch-0.9
in repository https://gitbox.apache.org/repos/asf/gravitino.git


The following commit(s) were added to refs/heads/branch-0.9 by this push:
     new 64d47efb39 [#5660] fix (trino-connector):  Fix failed to Load 
Postgresql Array data in Trino (#8234)
64d47efb39 is described below

commit 64d47efb39cca5d4a7e18654dda33978d9cf4b67
Author: github-actions[bot] 
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Thu Aug 21 14:38:19 2025 +0800

    [#5660] fix (trino-connector):  Fix failed to Load Postgresql Array data in 
Trino (#8234)
    
    ### What changes were proposed in this pull request?
    
    (Please outline the changes and how this PR fixes the issue.)
    
    ### Why are the changes needed?
    
    Fix: #5660
    
    ### Does this PR introduce _any_ user-facing change?
    
    NO
    
    ### How was this patch tested?
    
    Manually test
    
    Co-authored-by: Yuhui <[email protected]>
---
 .../catalog/jdbc/postgresql/PostgreSQLConnectorAdapter.java         | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git 
a/trino-connector/trino-connector/src/main/java/org/apache/gravitino/trino/connector/catalog/jdbc/postgresql/PostgreSQLConnectorAdapter.java
 
b/trino-connector/trino-connector/src/main/java/org/apache/gravitino/trino/connector/catalog/jdbc/postgresql/PostgreSQLConnectorAdapter.java
index c68d282b06..d4c9930ecf 100644
--- 
a/trino-connector/trino-connector/src/main/java/org/apache/gravitino/trino/connector/catalog/jdbc/postgresql/PostgreSQLConnectorAdapter.java
+++ 
b/trino-connector/trino-connector/src/main/java/org/apache/gravitino/trino/connector/catalog/jdbc/postgresql/PostgreSQLConnectorAdapter.java
@@ -20,6 +20,7 @@ package 
org.apache.gravitino.trino.connector.catalog.jdbc.postgresql;
 
 import static java.util.Collections.emptyList;
 
+import java.util.HashMap;
 import java.util.Map;
 import org.apache.gravitino.catalog.property.PropertyConverter;
 import org.apache.gravitino.trino.connector.catalog.CatalogConnectorAdapter;
@@ -41,7 +42,10 @@ public class PostgreSQLConnectorAdapter implements 
CatalogConnectorAdapter {
   @Override
   public Map<String, String> buildInternalConnectorConfig(GravitinoCatalog 
catalog)
       throws Exception {
-    return 
catalogConverter.gravitinoToEngineProperties(catalog.getProperties());
+    Map<String, String> trinoProperty =
+        new 
HashMap<>(catalogConverter.gravitinoToEngineProperties(catalog.getProperties()));
+    trinoProperty.put("postgresql.array-mapping", "AS_ARRAY");
+    return trinoProperty;
   }
 
   @Override

Reply via email to