You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
select * from "icebergtable$files@7046541185529900854";
However the query:
select * from "icebergtable$files" for version as of 7046541185529900854;
fails with the exception:
io.trino.spi.TrinoException: This connector does not support versioned tables
at io.trino.spi.connector.ConnectorMetadata.isSupportedVersionType(ConnectorMetadata.java:1319)
at io.trino.metadata.MetadataManager.isValidTableVersion(MetadataManager.java:2415)
at io.trino.sql.analyzer.StatementAnalyzer$Visitor.extractTableVersion(StatementAnalyzer.java:4579)
at io.trino.sql.analyzer.StatementAnalyzer$Visitor.getTableHandle(StatementAnalyzer.java:4543)
at io.trino.sql.analyzer.StatementAnalyzer$Visitor.visitTable(StatementAnalyzer.java:1771)
at io.trino.sql.analyzer.StatementAnalyzer$Visitor.visitTable(StatementAnalyzer.java:436)
at io.trino.sql.tree.Table.accept(Table.java:60)
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)
The problem is lied to the fact that "icebergtable$files" translates to SystemTablesMetadata which has no implementation for the method io.trino.spi.connector.ConnectorMetadata#isSupportedVersionType
In any case extracting the start version and end version shouldn't be done in StatementAnalyzer but in IcebergMetadata
Also SystemTablesMetadata should have an implementation for the interface method getTableHandle(io.trino.spi.connector.ConnectorSession, io.trino.spi.connector.SchemaTableName, java.util.Optional<io.trino.spi.connector.ConnectorTableVersion>, java.util.Optional<io.trino.spi.connector.ConnectorTableVersion>)
The text was updated successfully, but these errors were encountered:
The following versioned query works OK:
However the query:
fails with the exception:
The problem is lied to the fact that "icebergtable$files" translates to
SystemTablesMetadata
which has no implementation for the methodio.trino.spi.connector.ConnectorMetadata#isSupportedVersionType
In any case extracting the start version and end version shouldn't be done in
StatementAnalyzer
but inIcebergMetadata
trino/core/trino-main/src/main/java/io/trino/sql/analyzer/StatementAnalyzer.java
Lines 4541 to 4544 in 8416256
Also
SystemTablesMetadata
should have an implementation for the interface methodgetTableHandle(io.trino.spi.connector.ConnectorSession, io.trino.spi.connector.SchemaTableName, java.util.Optional<io.trino.spi.connector.ConnectorTableVersion>, java.util.Optional<io.trino.spi.connector.ConnectorTableVersion>)
The text was updated successfully, but these errors were encountered: