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