diff --git a/plugin/trino-base-jdbc/src/main/java/io/trino/plugin/jdbc/JdbcRecordCursor.java b/plugin/trino-base-jdbc/src/main/java/io/trino/plugin/jdbc/JdbcRecordCursor.java index 6710951fe93a..2768c4077594 100644 --- a/plugin/trino-base-jdbc/src/main/java/io/trino/plugin/jdbc/JdbcRecordCursor.java +++ b/plugin/trino-base-jdbc/src/main/java/io/trino/plugin/jdbc/JdbcRecordCursor.java @@ -83,7 +83,7 @@ public JdbcRecordCursor(JdbcClient jdbcClient, ExecutorService executor, Connect for (int i = 0; i < this.columnHandles.length; i++) { JdbcColumnHandle columnHandle = columnHandles.get(i); ColumnMapping columnMapping = jdbcClient.toColumnMapping(session, connection, columnHandle.getJdbcTypeHandle()) - .orElseThrow(() -> new VerifyException("Unsupported column type")); + .orElseThrow(() -> new VerifyException("Column %s has unsupported type %s".formatted(columnHandle.getColumnName(), columnHandle.getJdbcTypeHandle()))); verify( columnHandle.getColumnType().equals(columnMapping.getType()), "Type mismatch: column handle has type %s but %s is mapped to %s",