(gravitino) branch main updated: [#7403] fix(core): Fix bugs in SQL session commit in the core module (#7404)

[jshao]

This is an automated email from the ASF dual-hosted git repository.

jshao pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/gravitino.git


The following commit(s) were added to refs/heads/main by this push:
     new b16a07fd59 [#7403] fix(core): Fix bugs in SQL session commit in the 
core module (#7404)
b16a07fd59 is described below

commit b16a07fd5920e0a62b34636450445a612651fc89
Author: Mini Yu <y...@datastrato.com>
AuthorDate: Mon Jun 16 23:57:15 2025 +0800

    [#7403] fix(core): Fix bugs in SQL session commit in the core module (#7404)
    
    ### What changes were proposed in this pull request?
    
    Replace `doWithCommitAndFetchResult` with
    `doWithoutCommitAndFetchResult` in the method `deleteColumnsByTableId`.
    
    ### Why are the changes needed?
    
    The method is used in `doMultipleWithCommit` and should not use
    `doWithCommitAndFetchResult`.
    
    Fix: #7403
    
    ### Does this PR introduce _any_ user-facing change?
    
    N/A.
    
    ### How was this patch tested?
    
    Existing UTs and ITs.
---
 .../gravitino/storage/relational/service/TableColumnMetaService.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/core/src/main/java/org/apache/gravitino/storage/relational/service/TableColumnMetaService.java
 
b/core/src/main/java/org/apache/gravitino/storage/relational/service/TableColumnMetaService.java
index 9e2b3530d0..1527811fa9 100644
--- 
a/core/src/main/java/org/apache/gravitino/storage/relational/service/TableColumnMetaService.java
+++ 
b/core/src/main/java/org/apache/gravitino/storage/relational/service/TableColumnMetaService.java
@@ -100,7 +100,7 @@ public class TableColumnMetaService {
   boolean deleteColumnsByTableId(Long tableId) {
     // deleteColumns will be done in deleteTable transaction, so we don't do 
commit here.
     Integer result =
-        SessionUtils.doWithCommitAndFetchResult(
+        SessionUtils.doWithoutCommitAndFetchResult(
             TableColumnMapper.class, mapper -> 
mapper.softDeleteColumnsByTableId(tableId));
     return result > 0;
   }