File tree 1 file changed +7
-3
lines changed
cloud_gcp/src/main/scala/ai/chronon/integrations/cloud_gcp 1 file changed +7
-3
lines changed Original file line number Diff line number Diff line change @@ -138,9 +138,10 @@ class DelegatingBigQueryMetastoreCatalog extends TableCatalog with SupportsNames
138
138
s " Table identifier namespace ${identNoCatalog} must have at least one part. " )
139
139
}
140
140
logger.info(s " Catalog TableID: ${tId.toString}" )
141
- val table = bigQueryClient.getTable(tId)
142
- logger.info(s " Got table: ${table.getFriendlyName}" )
143
- table.getDefinition.asInstanceOf [TableDefinition ] match {
141
+ try {
142
+ val table = bigQueryClient.getTable(tId)
143
+ logger.info(s " Got table: ${table.getFriendlyName}" )
144
+ table.getDefinition.asInstanceOf [TableDefinition ] match {
144
145
case externalTable : ExternalTableDefinition => {
145
146
val uris = externalTable.getSourceUris.asScala
146
147
val uri = scala
@@ -175,6 +176,9 @@ class DelegatingBigQueryMetastoreCatalog extends TableCatalog with SupportsNames
175
176
}
176
177
case _ => throw new IllegalStateException (s " Cannot support table of type: ${table.getFriendlyName}" )
177
178
}
179
+ } catch {
180
+ case e : Exception => logger.info(" Got exception loading table" , e)
181
+ }
178
182
}
179
183
}
180
184
.getOrElse(throw new NoSuchTableException (f " Table: ${identNoCatalog} not found in bigquery catalog. " ))
You can’t perform that action at this time.
0 commit comments