Snowflake connector - catalog not found. - Please advise. #22222
Replies: 1 comment
-
This works with 4.4.9 - fails on 4.4.8 ! Thank you. |
Beta Was this translation helpful? Give feedback.
0 replies
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Uh oh!
There was an error while loading. Please reload this page.
Uh oh!
There was an error while loading. Please reload this page.
-
I'm using trino 4.4.8 on Ubuntu, python 3.11.
The catalog loads fine on startup :
2024-05-31T12:07:09.913Z INFO main Bootstrap snowflake.account ---- account.eu-central-2.aws
2024-05-31T12:07:09.913Z INFO main Bootstrap snowflake.database ---- SNOWFLAKE_SAMPLE_DATA
2024-05-31T12:07:09.913Z INFO main Bootstrap snowflake.http-proxy [REDACTED] [REDACTED]
2024-05-31T12:07:09.913Z INFO main Bootstrap snowflake.role ---- accountadmin
2024-05-31T12:07:09.913Z INFO main Bootstrap snowflake.warehouse ---- COMPUTE_WH
2024-05-31T12:07:10.389Z INFO main io.trino.connector.StaticCatalogManager -- Added catalog SNOWFLAKE_SAMPLE_DATA using connector snowflake --
I get the following error, when I run code/queries:
pyhive.exc.DatabaseError: {'message': "line 1:15: Catalog 'snowflake_sample_data' not found", 'errorCode': 44, 'errorName': 'CATALOG_NOT_FOUND', 'errorType': 'USER_ERROR', 'errorLocation': {'lineNumber': 1, 'columnNumber': 15}, 'failureInfo': {'type': 'io.trino.spi.TrinoException', 'message': "line 1:15: Catalog 'snowflake_sample_data' not found", 'suppressed': [], 'stack': ['io.trino.sql.analyzer.SemanticExceptions.semanticException(SemanticExceptions.java:52)', 'io.trino.sql.analyzer.SemanticExceptions.semanticException(SemanticExceptions.java:46)', 'io.trino.metadata.MetadataUtil.lambda$getRequiredCatalogHandle$2(MetadataUtil.java:110)', 'java.base/java.util.Optional.orElseThrow(Optional.java:403)', 'io.trino.metadata.MetadataUtil.getRequiredCatalogHandle(MetadataUtil.java:110)', 'io.trino.sql.analyzer.StatementAnalyzer$Visitor.visitTable(StatementAnalyzer.java:2292)', 'io.trino.sql.analyzer.StatementAnalyzer$Visitor.visitTable(StatementAnalyzer.java:520)', 'io.trino.sql.tree.Table.accept(Table.java:60)', 'io.trino.sql.tree.AstVisitor.process(AstVisitor.java:27)', 'io.trino.sql.analyzer.StatementAnalyzer$Visitor.process(StatementAnalyzer.java:539)', 'io.trino.sql.analyzer.StatementAnalyzer$Visitor.analyzeFrom(StatementAnalyzer.java:4882)', 'io.trino.sql.analyzer.StatementAnalyzer$Visitor.visitQuerySpecification(StatementAnalyzer.java:3076)', 'io.trino.sql.analyzer.StatementAnalyzer$Visitor.visitQuerySpecification(StatementAnalyzer.java:520)', '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:539)', 'io.trino.sql.analyzer.StatementAnalyzer$Visitor.process(StatementAnalyzer.java:547)', 'io.trino.sql.analyzer.StatementAnalyzer$Visitor.visitQuery(StatementAnalyzer.java:1564)', 'io.trino.sql.analyzer.StatementAnalyzer$Visitor.visitQuery(StatementAnalyzer.java:520)', '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:539)', 'io.trino.sql.analyzer.StatementAnalyzer.analyze(StatementAnalyzer.java:499)', 'io.trino.sql.analyzer.StatementAnalyzer.analyze(StatementAnalyzer.java:488)', '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:285)', 'io.trino.execution.SqlQueryExecution.(SqlQueryExecution.java:218)', 'io.trino.execution.SqlQueryExecution$SqlQueryExecutionFactory.createQueryExecution(SqlQueryExecution.java:884)', 'io.trino.dispatcher.LocalDispatchQueryFactory.lambda$createDispatchQuery$0(LocalDispatchQueryFactory.java:153)', 'io.trino.$gen.Trino_448____20240531_131244_2.call(Unknown Source)', 'com.google.common.util.concurrent.TrustedListenableFutureTask$TrustedFutureInterruptibleTask.runInterruptibly(TrustedListenableFutureTask.java:131)', 'com.google.common.util.concurrent.InterruptibleTask.run(InterruptibleTask.java:76)', 'com.google.common.util.concurrent.TrustedListenableFutureTask.run(TrustedListenableFutureTask.java:82)', 'java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)', 'java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)', 'java.base/java.lang.Thread.run(Thread.java:1570)'], 'errorInfo': {'code': 44, 'name': 'CATALOG_NOT_FOUND', 'type': 'USER_ERROR'}, 'errorLocation': {'lineNumber': 1, 'columnNumber': 15}}}
Here is my catalog file :
connector.name=snowflake
connection-url=jdbc:snowflake://account .eu-central-2.aws.snowflakecomputing.com?ssl=true&sslmode=require
connection-user=user
connection-password=passwd
snowflake.account=account .eu-central-2.aws
snowflake.database=SNOWFLAKE_SAMPLE_DATA
snowflake.role=accountadmin
snowflake.warehouse=COMPUTE_WH
Beta Was this translation helpful? Give feedback.
All reactions