query() function not working for PostgreSQL connector

[Mast3rSensei]

I have Trino connected to a PostgreSQL database. Since converting my queries into a syntax accepted by PrestoSQL is too much work, I decided to try out querying the underlying database directly following the official Trino's documentation. However, when I try to run this:

select *
from table(my_postgres_catalog.system.query('select * from only apartment;'))

I get this error:
trino error: com.google.common.util.concurrent.UncheckedExecutionException: com.google.common.base.VerifyException: Case sensitivity not supported

I tried to add the case-insensitive-name-matching=true option to the catalog config file, but no luck. Can anyone explain why this error occurs and how to circumvent it?

[nineinchnick]

Can you include the full stack trace? Also, can you try running the query without the semicolon (;)?

[Mast3rSensei]

Wait though, THAT specific table I was trying to query doesn't have any ARRAY type column, so it must've been something else triggering the error. I was getting it before I added the case-insensitive-name-matching=true property (I added it exactly because I was trying to solve the problem) and I kept getting it even after, so I might as well eliminate that property from there.

AS for the unsupported-type-handling=CONVERT_TO_VARCHAR property, we had to use it because Trino was not converting the NUMERIC types, which solved our problem. Similar case for postgresql.array-mapping=AS_JSON.

Another aspect that bugs me a lot: although we managed to find out that the problem only affects some columns in some tables, I noticed that it is not possible to use the query() function to run any query that requires string parameters, such as

SELECT * FROM TABLE(my_postgres_catalog.system.query('
SELECT * FROM ONLY apartment WHERE apt_title IS 'Sunny Apartment'
'))

All because, since the query() function requires you to provide a string with the query inside (query('postgres_query')), the presence of other ' characters inside the query causes the wrong parsing of it. Seems to me a huge overlook from Trino. Any way to circumvent this?

[nineinchnick]

Have you tried escaping those single quotes? Run this:

SELECT * FROM TABLE(my_postgres_catalog.system.query('
SELECT * FROM ONLY apartment WHERE apt_title IS ''Sunny Apartment''
'))

Can you post the schema of that table you're trying to read? Maybe there's some other complex type.

[Mast3rSensei]

Have you tried escaping those single quotes?

Good call! This seems to have solved it (you might want to add this tip in the official documentation if you guys feel like it, just my two cents),

As for the table's data types, we mostly have:

• bigserial
• int8, int4, int2
• varchar
• text
• timestamptz
• bool
• date
• numeric
• geography
• other enums we manually created

[hashhar]

Just the CREATE TABLE + full stacktrace should be sufficient to reproduce this and fix it since the failure happens during analysis/planning (judging from the place where the VerifyException is thrown).

You can collect the stacktrace from the Web UI or by running Trino-CLI with --debug. You can collect CREATE TABLE from Trino via SHOW CREATE TABLE but it'd be better if you can collect it directly from postgres since you have data-types which won't get shown as matching postgres type in the Trino output.

[Mast3rSensei]

I tried everything to get the complete stack trace, with no luck. However, from the UI I could get the JSON format of the error. Not the best in terms of readability, but I really don't know what else to do to get the entire error message.

{
  "queryId" : "20231103_160246_00030_2mtm9",
  "session" : {
    "queryId" : "20231103_160246_00030_2mtm9",
    "querySpan" : { },
    "transactionId" : "682ec610-4e0f-4c22-9b7e-4604b1b3b0c2",
    "clientTransactionSupport" : true,
    "user" : "superset",
    "originalUser" : "superset",
    "groups" : [ ],
    "originalUserGroups" : [ ],
    "principal" : "superset",
    "enabledRoles" : [ ],
    "source" : "trino-cli",
    "path" : {
      "path" : [ {
        "catalogName" : "system",
        "schemaName" : "$query"
      }, {
        "catalogName" : "system",
        "schemaName" : "builtin"
      } ],
      "rawPath" : ""
    },
    "timeZoneKey" : 2070,
    "locale" : "en_US",
    "remoteUserAddress" : "195.23.198.243",
    "userAgent" : "StatementClientV1/430",
    "clientTags" : [ ],
    "clientCapabilities" : [ "PATH", "PARAMETRIC_DATETIME", "SESSION_AUTHORIZATION" ],
    "resourceEstimates" : { },
    "start" : "2023-11-03T16:02:46.877387791Z",
    "systemProperties" : { },
    "catalogProperties" : { },
    "catalogRoles" : { },
    "preparedStatements" : { },
    "protocolName" : "Trino",
    "timeZone" : "Europe/Lisbon"
  },
  "state" : "FAILED",
  "self" : "https://172-17-0-2.ip:8443/v1/query/20231103_160246_00030_2mtm9",
  "fieldNames" : [ ],
  "query" : "select *\nfrom table(dbreplica1.system.query('select * from only apartment'))",
  "queryStats" : {
    "createTime" : "2023-11-03T16:02:46.879Z",
    "executionStartTime" : "2023-11-03T16:02:47.693Z",
    "lastHeartbeat" : "2023-11-03T16:02:47.697Z",
    "endTime" : "2023-11-03T16:02:47.693Z",
    "elapsedTime" : "814.60ms",
    "queuedTime" : "1.78ms",
    "resourceWaitingTime" : "812.81ms",
    "dispatchingTime" : "0.00s",
    "executionTime" : "0.00s",
    "analysisTime" : "813.91ms",
    "planningTime" : "0.00s",
    "planningCpuTime" : "0.00s",
    "finishingTime" : "0.00s",
    "totalTasks" : 0,
    "runningTasks" : 0,
    "completedTasks" : 0,
    "failedTasks" : 0,
    "totalDrivers" : 0,
    "queuedDrivers" : 0,
    "runningDrivers" : 0,
    "blockedDrivers" : 0,
    "completedDrivers" : 0,
    "cumulativeUserMemory" : 0.0,
    "failedCumulativeUserMemory" : 0.0,
    "userMemoryReservation" : "0B",
    "revocableMemoryReservation" : "0B",
    "totalMemoryReservation" : "0B",
    "peakUserMemoryReservation" : "0B",
    "peakRevocableMemoryReservation" : "0B",
    "peakTotalMemoryReservation" : "0B",
    "peakTaskUserMemory" : "0B",
    "peakTaskRevocableMemory" : "0B",
    "peakTaskTotalMemory" : "0B",
    "scheduled" : false,
    "totalScheduledTime" : "0.00ns",
    "failedScheduledTime" : "0.00ns",
    "totalCpuTime" : "0.00ns",
    "failedCpuTime" : "0.00ns",
    "totalBlockedTime" : "0.00ns",
    "fullyBlocked" : false,
    "blockedReasons" : [ ],
    "physicalInputDataSize" : "0B",
    "failedPhysicalInputDataSize" : "0B",
    "physicalInputPositions" : 0,
    "failedPhysicalInputPositions" : 0,
    "physicalInputReadTime" : "0.00ns",
    "failedPhysicalInputReadTime" : "0.00ns",
    "internalNetworkInputDataSize" : "0B",
    "failedInternalNetworkInputDataSize" : "0B",
    "internalNetworkInputPositions" : 0,
    "failedInternalNetworkInputPositions" : 0,
    "rawInputDataSize" : "0B",
    "failedRawInputDataSize" : "0B",
    "rawInputPositions" : 0,
    "failedRawInputPositions" : 0,
    "processedInputDataSize" : "0B",
    "failedProcessedInputDataSize" : "0B",
    "processedInputPositions" : 0,
    "failedProcessedInputPositions" : 0,
    "inputBlockedTime" : "0.00ns",
    "failedInputBlockedTime" : "0.00ns",
    "outputDataSize" : "0B",
    "failedOutputDataSize" : "0B",
    "outputPositions" : 0,
    "failedOutputPositions" : 0,
    "outputBlockedTime" : "0.00ns",
    "failedOutputBlockedTime" : "0.00ns",
    "physicalWrittenDataSize" : "0B",
    "failedPhysicalWrittenDataSize" : "0B",
    "stageGcStatistics" : [ ],
    "dynamicFiltersStats" : {
      "dynamicFilterDomainStats" : [ ],
      "lazyDynamicFilters" : 0,
      "replicatedDynamicFilters" : 0,
      "totalDynamicFilters" : 0,
      "dynamicFiltersCompleted" : 0
    },
    "operatorSummaries" : [ ],
    "optimizerRulesSummaries" : [ ],
    "logicalWrittenDataSize" : "0B",
    "writtenPositions" : 0,
    "spilledDataSize" : "0B"
  },
  "resetAuthorizationUser" : false,
  "setSessionProperties" : { },
  "resetSessionProperties" : [ ],
  "setRoles" : { },
  "addedPreparedStatements" : { },
  "deallocatedPreparedStatements" : [ ],
  "clearTransactionId" : false,
  "failureInfo" : {
    "type" : "com.google.common.util.concurrent.UncheckedExecutionException",
    "message" : "com.google.common.util.concurrent.UncheckedExecutionException: com.google.common.base.VerifyException: Case sensitivity not supported",
    "cause" : {
      "type" : "com.google.common.util.concurrent.UncheckedExecutionException",
      "message" : "com.google.common.base.VerifyException: Case sensitivity not supported",
      "cause" : {
        "type" : "com.google.common.base.VerifyException",
        "message" : "Case sensitivity not supported",
        "suppressed" : [ ],
        "stack" : [ "com.google.common.base.Verify.verify(Verify.java:126)", "io.trino.plugin.postgresql.PostgreSqlClient.getArrayElementTypeHandle(PostgreSqlClient.java:1428)", "io.trino.plugin.postgresql.PostgreSqlClient.arrayToTrinoType(PostgreSqlClient.java:631)", "io.trino.plugin.postgresql.PostgreSqlClient.toColumnMapping(PostgreSqlClient.java:608)", "io.trino.plugin.jdbc.BaseJdbcClient.getColumns(BaseJdbcClient.java:281)", "io.trino.plugin.jdbc.BaseJdbcClient.getTableHandle(BaseJdbcClient.java:249)", "io.trino.plugin.jdbc.ForwardingJdbcClient.getTableHandle(ForwardingJdbcClient.java:94)", "io.trino.plugin.jdbc.jmx.StatisticsAwareJdbcClient.lambda$getTableHandle$4(StatisticsAwareJdbcClient.java:115)", "io.trino.plugin.jdbc.jmx.JdbcApiStats.wrap(JdbcApiStats.java:34)", "io.trino.plugin.jdbc.jmx.StatisticsAwareJdbcClient.getTableHandle(StatisticsAwareJdbcClient.java:115)", "io.trino.plugin.jdbc.CachingJdbcClient.lambda$getTableHandle$5(CachingJdbcClient.java:357)", "io.trino.cache.EmptyCache.get(EmptyCache.java:94)", "io.trino.plugin.jdbc.CachingJdbcClient.get(CachingJdbcClient.java:758)", "io.trino.plugin.jdbc.CachingJdbcClient.getTableHandle(CachingJdbcClient.java:357)", "io.trino.plugin.jdbc.CachingJdbcClient.lambda$getTableHandle$5(CachingJdbcClient.java:357)", "com.google.common.cache.LocalCache$LocalManualCache$1.load(LocalCache.java:4927)", "com.google.common.cache.LocalCache$LoadingValueReference.loadFuture(LocalCache.java:3571)", "com.google.common.cache.LocalCache$Segment.loadSync(LocalCache.java:2313)", "com.google.common.cache.LocalCache$Segment.lockedGetOrLoad(LocalCache.java:2190)", "com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2080)", "com.google.common.cache.LocalCache.get(LocalCache.java:4012)", "com.google.common.cache.LocalCache$LocalManualCache.get(LocalCache.java:4922)", "io.trino.cache.EvictableCache.get(EvictableCache.java:112)", "io.trino.plugin.jdbc.CachingJdbcClient.get(CachingJdbcClient.java:758)", "io.trino.plugin.jdbc.CachingJdbcClient.getTableHandle(CachingJdbcClient.java:357)", "io.trino.plugin.jdbc.DefaultJdbcMetadata.getTableHandle(DefaultJdbcMetadata.java:151)", "io.trino.plugin.jdbc.ptf.Query$QueryFunction.analyze(Query.java:102)", "io.trino.plugin.base.classloader.ClassLoaderSafeConnectorTableFunction.analyze(ClassLoaderSafeConnectorTableFunction.java:82)", "io.trino.sql.analyzer.StatementAnalyzer$Visitor.visitTableFunctionInvocation(StatementAnalyzer.java:1648)", "io.trino.sql.analyzer.StatementAnalyzer$Visitor.visitTableFunctionInvocation(StatementAnalyzer.java:497)", "io.trino.sql.tree.TableFunctionInvocation.accept(TableFunctionInvocation.java:56)", "io.trino.sql.tree.AstVisitor.process(AstVisitor.java:27)", "io.trino.sql.analyzer.StatementAnalyzer$Visitor.process(StatementAnalyzer.java:516)", "io.trino.sql.analyzer.StatementAnalyzer$Visitor.analyzeFrom(StatementAnalyzer.java:4579)", "io.trino.sql.analyzer.StatementAnalyzer$Visitor.visitQuerySpecification(StatementAnalyzer.java:3039)", "io.trino.sql.analyzer.StatementAnalyzer$Visitor.visitQuerySpecification(StatementAnalyzer.java:497)", "io.trino.sql.tree.QuerySpecification.accept(QuerySpecification.java:155)", "io.trino.sql.tree.AstVisitor.process(AstVisitor.java:27)", "io.trino.sql.analyzer.StatementAnalyzer$Visitor.process(StatementAnalyzer.java:516)", "io.trino.sql.analyzer.StatementAnalyzer$Visitor.process(StatementAnalyzer.java:524)", "io.trino.sql.analyzer.StatementAnalyzer$Visitor.visitQuery(StatementAnalyzer.java:1535)", "io.trino.sql.analyzer.StatementAnalyzer$Visitor.visitQuery(StatementAnalyzer.java:497)", "io.trino.sql.tree.Query.accept(Query.java:118)", "io.trino.sql.tree.AstVisitor.process(AstVisitor.java:27)", "io.trino.sql.analyzer.StatementAnalyzer$Visitor.process(StatementAnalyzer.java:516)", "io.trino.sql.analyzer.StatementAnalyzer.analyze(StatementAnalyzer.java:476)", "io.trino.sql.analyzer.StatementAnalyzer.analyze(StatementAnalyzer.java:465)", "io.trino.sql.analyzer.Analyzer.analyze(Analyzer.java:97)", "io.trino.sql.analyzer.Analyzer.analyze(Analyzer.java:86)", "io.trino.execution.SqlQueryExecution.analyze(SqlQueryExecution.java:274)", "io.trino.execution.SqlQueryExecution.<init>(SqlQueryExecution.java:209)", "io.trino.execution.SqlQueryExecution$SqlQueryExecutionFactory.createQueryExecution(SqlQueryExecution.java:850)", "io.trino.dispatcher.LocalDispatchQueryFactory.lambda$createDispatchQuery$0(LocalDispatchQueryFactory.java:153)", "io.trino.$gen.Trino_431____20231102_163241_2.call(Unknown Source)", "com.google.common.util.concurrent.TrustedListenableFutureTask$TrustedFutureInterruptibleTask.runInterruptibly(TrustedListenableFutureTask.java:131)", "com.google.common.util.concurrent.InterruptibleTask.run(InterruptibleTask.java:75)", "com.google.common.util.concurrent.TrustedListenableFutureTask.run(TrustedListenableFutureTask.java:82)", "java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)", "java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)", "java.base/java.lang.Thread.run(Thread.java:833)" ],
        "errorCode" : {
          "code" : 65536,
          "name" : "GENERIC_INTERNAL_ERROR",
          "type" : "INTERNAL_ERROR"
        }
      },
      "suppressed" : [ ],
      "stack" : [ "io.trino.cache.EmptyCache.get(EmptyCache.java:100)", "io.trino.plugin.jdbc.CachingJdbcClient.get(CachingJdbcClient.java:758)", "io.trino.plugin.jdbc.CachingJdbcClient.getTableHandle(CachingJdbcClient.java:357)", "io.trino.plugin.jdbc.CachingJdbcClient.lambda$getTableHandle$5(CachingJdbcClient.java:357)", "com.google.common.cache.LocalCache$LocalManualCache$1.load(LocalCache.java:4927)", "com.google.common.cache.LocalCache$LoadingValueReference.loadFuture(LocalCache.java:3571)", "com.google.common.cache.LocalCache$Segment.loadSync(LocalCache.java:2313)", "com.google.common.cache.LocalCache$Segment.lockedGetOrLoad(LocalCache.java:2190)", "com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2080)", "com.google.common.cache.LocalCache.get(LocalCache.java:4012)", "com.google.common.cache.LocalCache$LocalManualCache.get(LocalCache.java:4922)", "io.trino.cache.EvictableCache.get(EvictableCache.java:112)", "io.trino.plugin.jdbc.CachingJdbcClient.get(CachingJdbcClient.java:758)", "io.trino.plugin.jdbc.CachingJdbcClient.getTableHandle(CachingJdbcClient.java:357)", "io.trino.plugin.jdbc.DefaultJdbcMetadata.getTableHandle(DefaultJdbcMetadata.java:151)", "io.trino.plugin.jdbc.ptf.Query$QueryFunction.analyze(Query.java:102)", "io.trino.plugin.base.classloader.ClassLoaderSafeConnectorTableFunction.analyze(ClassLoaderSafeConnectorTableFunction.java:82)", "io.trino.sql.analyzer.StatementAnalyzer$Visitor.visitTableFunctionInvocation(StatementAnalyzer.java:1648)", "io.trino.sql.analyzer.StatementAnalyzer$Visitor.visitTableFunctionInvocation(StatementAnalyzer.java:497)", "io.trino.sql.tree.TableFunctionInvocation.accept(TableFunctionInvocation.java:56)", "io.trino.sql.tree.AstVisitor.process(AstVisitor.java:27)", "io.trino.sql.analyzer.StatementAnalyzer$Visitor.process(StatementAnalyzer.java:516)", "io.trino.sql.analyzer.StatementAnalyzer$Visitor.analyzeFrom(StatementAnalyzer.java:4579)", "io.trino.sql.analyzer.StatementAnalyzer$Visitor.visitQuerySpecification(StatementAnalyzer.java:3039)", "io.trino.sql.analyzer.StatementAnalyzer$Visitor.visitQuerySpecification(StatementAnalyzer.java:497)", "io.trino.sql.tree.QuerySpecification.accept(QuerySpecification.java:155)", "io.trino.sql.tree.AstVisitor.process(AstVisitor.java:27)", "io.trino.sql.analyzer.StatementAnalyzer$Visitor.process(StatementAnalyzer.java:516)", "io.trino.sql.analyzer.StatementAnalyzer$Visitor.process(StatementAnalyzer.java:524)", "io.trino.sql.analyzer.StatementAnalyzer$Visitor.visitQuery(StatementAnalyzer.java:1535)", "io.trino.sql.analyzer.StatementAnalyzer$Visitor.visitQuery(StatementAnalyzer.java:497)", "io.trino.sql.tree.Query.accept(Query.java:118)", "io.trino.sql.tree.AstVisitor.process(AstVisitor.java:27)", "io.trino.sql.analyzer.StatementAnalyzer$Visitor.process(StatementAnalyzer.java:516)", "io.trino.sql.analyzer.StatementAnalyzer.analyze(StatementAnalyzer.java:476)", "io.trino.sql.analyzer.StatementAnalyzer.analyze(StatementAnalyzer.java:465)", "io.trino.sql.analyzer.Analyzer.analyze(Analyzer.java:97)", "io.trino.sql.analyzer.Analyzer.analyze(Analyzer.java:86)", "io.trino.execution.SqlQueryExecution.analyze(SqlQueryExecution.java:274)", "io.trino.execution.SqlQueryExecution.<init>(SqlQueryExecution.java:209)", "io.trino.execution.SqlQueryExecution$SqlQueryExecutionFactory.createQueryExecution(SqlQueryExecution.java:850)", "io.trino.dispatcher.LocalDispatchQueryFactory.lambda$createDispatchQuery$0(LocalDispatchQueryFactory.java:153)", "io.trino.$gen.Trino_431____20231102_163241_2.call(Unknown Source)", "com.google.common.util.concurrent.TrustedListenableFutureTask$TrustedFutureInterruptibleTask.runInterruptibly(TrustedListenableFutureTask.java:131)", "com.google.common.util.concurrent.InterruptibleTask.run(InterruptibleTask.java:75)", "com.google.common.util.concurrent.TrustedListenableFutureTask.run(TrustedListenableFutureTask.java:82)", "java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)", "java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)", "java.base/java.lang.Thread.run(Thread.java:833)" ],
      "errorCode" : {
        "code" : 65536,
        "name" : "GENERIC_INTERNAL_ERROR",
        "type" : "INTERNAL_ERROR"
      }
    },
    "suppressed" : [ ],
    "stack" : [ "com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2086)", "com.google.common.cache.LocalCache.get(LocalCache.java:4012)", "com.google.common.cache.LocalCache$LocalManualCache.get(LocalCache.java:4922)", "io.trino.cache.EvictableCache.get(EvictableCache.java:112)", "io.trino.plugin.jdbc.CachingJdbcClient.get(CachingJdbcClient.java:758)", "io.trino.plugin.jdbc.CachingJdbcClient.getTableHandle(CachingJdbcClient.java:357)", "io.trino.plugin.jdbc.DefaultJdbcMetadata.getTableHandle(DefaultJdbcMetadata.java:151)", "io.trino.plugin.jdbc.ptf.Query$QueryFunction.analyze(Query.java:102)", "io.trino.plugin.base.classloader.ClassLoaderSafeConnectorTableFunction.analyze(ClassLoaderSafeConnectorTableFunction.java:82)", "io.trino.sql.analyzer.StatementAnalyzer$Visitor.visitTableFunctionInvocation(StatementAnalyzer.java:1648)", "io.trino.sql.analyzer.StatementAnalyzer$Visitor.visitTableFunctionInvocation(StatementAnalyzer.java:497)", "io.trino.sql.tree.TableFunctionInvocation.accept(TableFunctionInvocation.java:56)", "io.trino.sql.tree.AstVisitor.process(AstVisitor.java:27)", "io.trino.sql.analyzer.StatementAnalyzer$Visitor.process(StatementAnalyzer.java:516)", "io.trino.sql.analyzer.StatementAnalyzer$Visitor.analyzeFrom(StatementAnalyzer.java:4579)", "io.trino.sql.analyzer.StatementAnalyzer$Visitor.visitQuerySpecification(StatementAnalyzer.java:3039)", "io.trino.sql.analyzer.StatementAnalyzer$Visitor.visitQuerySpecification(StatementAnalyzer.java:497)", "io.trino.sql.tree.QuerySpecification.accept(QuerySpecification.java:155)", "io.trino.sql.tree.AstVisitor.process(AstVisitor.java:27)", "io.trino.sql.analyzer.StatementAnalyzer$Visitor.process(StatementAnalyzer.java:516)", "io.trino.sql.analyzer.StatementAnalyzer$Visitor.process(StatementAnalyzer.java:524)", "io.trino.sql.analyzer.StatementAnalyzer$Visitor.visitQuery(StatementAnalyzer.java:1535)", "io.trino.sql.analyzer.StatementAnalyzer$Visitor.visitQuery(StatementAnalyzer.java:497)", "io.trino.sql.tree.Query.accept(Query.java:118)", "io.trino.sql.tree.AstVisitor.process(AstVisitor.java:27)", "io.trino.sql.analyzer.StatementAnalyzer$Visitor.process(StatementAnalyzer.java:516)", "io.trino.sql.analyzer.StatementAnalyzer.analyze(StatementAnalyzer.java:476)", "io.trino.sql.analyzer.StatementAnalyzer.analyze(StatementAnalyzer.java:465)", "io.trino.sql.analyzer.Analyzer.analyze(Analyzer.java:97)", "io.trino.sql.analyzer.Analyzer.analyze(Analyzer.java:86)", "io.trino.execution.SqlQueryExecution.analyze(SqlQueryExecution.java:274)", "io.trino.execution.SqlQueryExecution.<init>(SqlQueryExecution.java:209)", "io.trino.execution.SqlQueryExecution$SqlQueryExecutionFactory.createQueryExecution(SqlQueryExecution.java:850)", "io.trino.dispatcher.LocalDispatchQueryFactory.lambda$createDispatchQuery$0(LocalDispatchQueryFactory.java:153)", "io.trino.$gen.Trino_431____20231102_163241_2.call(Unknown Source)", "com.google.common.util.concurrent.TrustedListenableFutureTask$TrustedFutureInterruptibleTask.runInterruptibly(TrustedListenableFutureTask.java:131)", "com.google.common.util.concurrent.InterruptibleTask.run(InterruptibleTask.java:75)", "com.google.common.util.concurrent.TrustedListenableFutureTask.run(TrustedListenableFutureTask.java:82)", "java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)", "java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)", "java.base/java.lang.Thread.run(Thread.java:833)" ],
    "errorCode" : {
      "code" : 65536,
      "name" : "GENERIC_INTERNAL_ERROR",
      "type" : "INTERNAL_ERROR"
    }
  },
  "errorCode" : {
    "code" : 65536,
    "name" : "GENERIC_INTERNAL_ERROR",
    "type" : "INTERNAL_ERROR"
  },
  "warnings" : [ ],
  "inputs" : [ ],
  "referencedTables" : [ ],
  "routines" : [ ],
  "finalQueryInfo" : true,
  "resourceGroupId" : [ "global" ],
  "queryType" : "SELECT",
  "retryPolicy" : "NONE",
  "pruned" : false,
  "version" : {
    "version" : "431"
  },
  "errorType" : "INTERNAL_ERROR",
  "scheduled" : false
}

[shaunlandau1973]

I'm seeing the same issue (trino 385 and 433). My query:

select *
from table (proton_think.system.query(query => '
select
account_id
, array_agg(flag_type) flag_type
from billing.account_flags
group by account_id')) f

account_id is bigint
flag_type is text

Stack trace (trino 385) is:

com.google.common.util.concurrent.UncheckedExecutionException: com.google.common.util.concurrent.UncheckedExecutionException: com.google.common.base.VerifyException: Case sensitivity not supported
at com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2055)
at com.google.common.cache.LocalCache.get(LocalCache.java:3966)
at com.google.common.cache.LocalCache$LocalManualCache.get(LocalCache.java:4863)
at io.trino.collect.cache.EvictableCache.get(EvictableCache.java:108)
at io.trino.plugin.jdbc.CachingJdbcClient.get(CachingJdbcClient.java:745)
at io.trino.plugin.jdbc.CachingJdbcClient.getTableHandle(CachingJdbcClient.java:298)
at io.trino.plugin.jdbc.DefaultJdbcMetadata.getTableHandle(DefaultJdbcMetadata.java:135)
at io.trino.plugin.jdbc.ptf.Query$QueryFunction.analyze(Query.java:98)
at io.trino.plugin.base.classloader.ClassLoaderSafeConnectorTableFunction.analyze(ClassLoaderSafeConnectorTableFunction.java:78)
at io.trino.sql.analyzer.StatementAnalyzer$Visitor.visitTableFunctionInvocation(StatementAnalyzer.java:1492)
at io.trino.sql.analyzer.StatementAnalyzer$Visitor.visitTableFunctionInvocation(StatementAnalyzer.java:436)
at io.trino.sql.tree.TableFunctionInvocation.accept(TableFunctionInvocation.java:56)
at io.trino.sql.tree.AstVisitor.process(AstVisitor.java:27)
at io.trino.sql.analyzer.StatementAnalyzer$Visitor.process(StatementAnalyzer.java:453)
at io.trino.sql.analyzer.StatementAnalyzer$Visitor.visitAliasedRelation(StatementAnalyzer.java:2299)
at io.trino.sql.analyzer.StatementAnalyzer$Visitor.visitAliasedRelation(StatementAnalyzer.java:436)
at io.trino.sql.tree.AliasedRelation.accept(AliasedRelation.java:71)
at io.trino.sql.tree.AstVisitor.process(AstVisitor.java:27)
at io.trino.sql.analyzer.StatementAnalyzer$Visitor.process(StatementAnalyzer.java:453)
at io.trino.sql.analyzer.StatementAnalyzer$Visitor.analyzeFrom(StatementAnalyzer.java:3666)
at io.trino.sql.analyzer.StatementAnalyzer$Visitor.visitQuerySpecification(StatementAnalyzer.java:2405)
at io.trino.sql.analyzer.StatementAnalyzer$Visitor.visitQuerySpecification(StatementAnalyzer.java:436)
at io.trino.sql.tree.QuerySpecification.accept(QuerySpecification.java:155)
at io.trino.sql.tree.AstVisitor.process(AstVisitor.java:27)
at io.trino.sql.analyzer.StatementAnalyzer$Visitor.process(StatementAnalyzer.java:453)
at io.trino.sql.analyzer.StatementAnalyzer$Visitor.process(StatementAnalyzer.java:461)
at io.trino.sql.analyzer.StatementAnalyzer$Visitor.visitQuery(StatementAnalyzer.java:1377)
at io.trino.sql.analyzer.StatementAnalyzer$Visitor.visitQuery(StatementAnalyzer.java:436)
at io.trino.sql.tree.Query.accept(Query.java:107)
at io.trino.sql.tree.AstVisitor.process(AstVisitor.java:27)
at io.trino.sql.analyzer.StatementAnalyzer$Visitor.process(StatementAnalyzer.java:453)
at io.trino.sql.analyzer.StatementAnalyzer.analyze(StatementAnalyzer.java:416)
at io.trino.sql.analyzer.Analyzer.analyze(Analyzer.java:79)
at io.trino.sql.analyzer.Analyzer.analyze(Analyzer.java:71)
at io.trino.execution.SqlQueryExecution.analyze(SqlQueryExecution.java:269)
at io.trino.execution.SqlQueryExecution.(SqlQueryExecution.java:193)
at io.trino.execution.SqlQueryExecution$SqlQueryExecutionFactory.createQueryExecution(SqlQueryExecution.java:808)
at io.trino.dispatcher.LocalDispatchQueryFactory.lambda$createDispatchQuery$0(LocalDispatchQueryFactory.java:135)
at io.trino.$gen.Trino_385____20231126_080846_2.call(Unknown Source)
at com.google.common.util.concurrent.TrustedListenableFutureTask$TrustedFutureInterruptibleTask.runInterruptibly(TrustedListenableFutureTask.java:131)
at com.google.common.util.concurrent.InterruptibleTask.run(InterruptibleTask.java:74)
at com.google.common.util.concurrent.TrustedListenableFutureTask.run(TrustedListenableFutureTask.java:82)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:829)
Caused by: com.google.common.util.concurrent.UncheckedExecutionException: com.google.common.base.VerifyException: Case sensitivity not supported
at io.trino.collect.cache.EmptyCache.get(EmptyCache.java:72)
at io.trino.plugin.jdbc.CachingJdbcClient.get(CachingJdbcClient.java:745)
at io.trino.plugin.jdbc.CachingJdbcClient.getTableHandle(CachingJdbcClient.java:298)
at io.trino.plugin.jdbc.CachingJdbcClient.lambda$getTableHandle$5(CachingJdbcClient.java:298)
at com.google.common.cache.LocalCache$LocalManualCache$1.load(LocalCache.java:4868)
at com.google.common.cache.LocalCache$LoadingValueReference.loadFuture(LocalCache.java:3533)
at com.google.common.cache.LocalCache$Segment.loadSync(LocalCache.java:2282)
at com.google.common.cache.LocalCache$Segment.lockedGetOrLoad(LocalCache.java:2159)
at com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2049)
... 44 more
Caused by: com.google.common.base.VerifyException: Case sensitivity not supported
at com.google.common.base.Verify.verify(Verify.java:126)
at io.trino.plugin.postgresql.PostgreSqlClient.getArrayElementTypeHandle(PostgreSqlClient.java:1316)
at io.trino.plugin.postgresql.PostgreSqlClient.arrayToTrinoType(PostgreSqlClient.java:599)
at io.trino.plugin.postgresql.PostgreSqlClient.toColumnMapping(PostgreSqlClient.java:576)
at io.trino.plugin.jdbc.BaseJdbcClient.getTableHandle(BaseJdbcClient.java:247)
at io.trino.plugin.jdbc.ForwardingJdbcClient.getTableHandle(ForwardingJdbcClient.java:90)
at io.trino.plugin.jdbc.jmx.StatisticsAwareJdbcClient.lambda$getTableHandle$4(StatisticsAwareJdbcClient.java:110)
at io.trino.plugin.jdbc.jmx.JdbcApiStats.wrap(JdbcApiStats.java:35)
at io.trino.plugin.jdbc.jmx.StatisticsAwareJdbcClient.getTableHandle(StatisticsAwareJdbcClient.java:110)
at io.trino.plugin.jdbc.CachingJdbcClient.lambda$getTableHandle$5(CachingJdbcClient.java:298)
at io.trino.collect.cache.EmptyCache.get(EmptyCache.java:66)
... 52 more