This is an automated email from the ASF dual-hosted git repository.
michaelsmith pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/impala.git
The following commit(s) were added to refs/heads/master by this push:
new be4778aba IMPALA-14810: Add Iceberg commit to catalog timeline
be4778aba is described below
commit be4778aba166d24112354c8540993861a4a7e06c
Author: Csaba Ringhofer <[email protected]>
AuthorDate: Fri Mar 6 17:49:36 2026 +0100
IMPALA-14810: Add Iceberg commit to catalog timeline
This can take significant time and before the patch
it was added to the duration of "Got Metastore client".
Change-Id: I9a9a3110d63224ee6fb94ff1d2b966578de04864
Reviewed-on: http://gerrit.cloudera.org:8080/24073
Reviewed-by: Impala Public Jenkins <[email protected]>
Tested-by: Impala Public Jenkins <[email protected]>
---
fe/src/main/java/org/apache/impala/service/CatalogOpExecutor.java | 3 +++
1 file changed, 3 insertions(+)
diff --git a/fe/src/main/java/org/apache/impala/service/CatalogOpExecutor.java
b/fe/src/main/java/org/apache/impala/service/CatalogOpExecutor.java
index 3b3bbbf9c..b563a2708 100644
--- a/fe/src/main/java/org/apache/impala/service/CatalogOpExecutor.java
+++ b/fe/src/main/java/org/apache/impala/service/CatalogOpExecutor.java
@@ -2851,6 +2851,7 @@ public class CatalogOpExecutor {
IcebergCatalogOpExecutor.addCatalogVersionToTxn(
iceTxn, catalog_.getCatalogServiceId(),
modification.newVersionNumber());
iceTxn.commitTransaction();
+ catalogTimeline.markEvent("Committed Iceberg transaction");
} else {
dropTableStats(table, catalogTimeline);
}
@@ -3679,6 +3680,7 @@ public class CatalogOpExecutor {
iceTxn, catalog_.getCatalogServiceId(),
modification.newVersionNumber());
}
iceTxn.commitTransaction();
+ catalogTimeline.markEvent("Committed Iceberg transaction");
modification.markInflightEventRegistrationComplete();
modification.validateInProgressModificationComplete();
} catch (ImpalaException ex) {
@@ -8066,6 +8068,7 @@ public class CatalogOpExecutor {
DebugUtils.executeDebugAction(update.getDebug_action(),
DebugUtils.ICEBERG_COMMIT);
iceTxn.commitTransaction();
+ catalogTimeline.markEvent("Committed Iceberg transaction");
// If we have no information about the success of the commit, we should
not delete
// anything.
} catch (CommitStateUnknownException u) {
