Skip to content

Commit 8e64aa5

Browse files
lukasz-stecraunaqmorarka
authored andcommitted
Do not log error on aborted transaction
1 parent 5d545c0 commit 8e64aa5

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

core/trino-main/src/main/java/io/trino/execution/QueryStateMachine.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -112,6 +112,7 @@
112112
import static io.trino.operator.RetryPolicy.TASK;
113113
import static io.trino.server.DynamicFilterService.DynamicFiltersStats;
114114
import static io.trino.spi.StandardErrorCode.NOT_FOUND;
115+
import static io.trino.spi.StandardErrorCode.TRANSACTION_ALREADY_ABORTED;
115116
import static io.trino.spi.StandardErrorCode.USER_CANCELED;
116117
import static io.trino.spi.connector.StandardWarningCode.SPOOLING_NOT_SUPPORTED;
117118
import static io.trino.spi.resourcegroups.QueryType.SELECT;
@@ -419,7 +420,9 @@ private void collectCatalogMetadataMetrics()
419420
// the transaction can be committed or aborted concurrently, after the check is done.
420421
}
421422
catch (RuntimeException e) {
422-
QUERY_STATE_LOG.error(e, "Error collecting query catalog metadata metrics: %s", queryId);
423+
if (!(e instanceof TrinoException trinoException && TRANSACTION_ALREADY_ABORTED.toErrorCode().equals(trinoException.getErrorCode()))) {
424+
QUERY_STATE_LOG.error(e, "Error collecting query catalog metadata metrics: %s", queryId);
425+
}
423426
}
424427
}
425428

0 commit comments

Comments
 (0)