fix

apache · Nov 18, 2024 · 58b66cd · 58b66cd
1 parent 29755a6
commit 58b66cd
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 5 deletions.
diff --git a/be/src/cloud/cloud_schema_change_job.cpp b/be/src/cloud/cloud_schema_change_job.cpp
@@ -349,7 +349,7 @@ Status CloudSchemaChangeJob::_convert_historical_rowsets(const SchemaChangeParam
             size_output_rowsets += rs->total_disk_size();
             num_output_segments += rs->num_segments();
             index_size_output_rowsets += rs->index_disk_size();
-            segment_size_output_rowsets += rs->data_disk_size()
+            segment_size_output_rowsets += rs->data_disk_size();
         }
         sc_job->set_num_output_rows(num_output_rows);
         sc_job->set_size_output_rowsets(size_output_rowsets);

diff --git a/regression-test/suites/inverted_index_p1/show_data/test_show_index_data.groovy b/regression-test/suites/inverted_index_p1/show_data/test_show_index_data.groovy
@@ -156,8 +156,9 @@ suite("test_show_index_data", "p1") {
             });
         }
 
-        int afterSegmentCount = 0
+
         for (def tablet in tablets) {
+            int afterSegmentCount = 0
             String tablet_id = tablet.TabletId
             (code, out, err) = curl("GET", tablet.CompactionStatus)
             logger.info("Show tablets status: code=" + code + ", out=" + out + ", err=" + err)
@@ -168,8 +169,8 @@ suite("test_show_index_data", "p1") {
                 logger.info("rowset is: " + rowset)
                 afterSegmentCount += Integer.parseInt(rowset.split(" ")[1])
             }
+            assertEquals(afterSegmentCount, 1)
         }
-        assertEquals(afterSegmentCount, 1)
     }
 
     double localIndexSize = 0

diff --git a/regression-test/suites/inverted_index_p2/show_data/test_show_index_data_p2.groovy b/regression-test/suites/inverted_index_p2/show_data/test_show_index_data_p2.groovy
@@ -156,8 +156,8 @@ suite("test_show_index_data_p2", "p2") {
             });
         }
 
-        int afterSegmentCount = 0
         for (def tablet in tablets) {
+            int afterSegmentCount = 0
             String tablet_id = tablet.TabletId
             (code, out, err) = curl("GET", tablet.CompactionStatus)
             logger.info("Show tablets status: code=" + code + ", out=" + out + ", err=" + err)
@@ -168,8 +168,9 @@ suite("test_show_index_data_p2", "p2") {
                 logger.info("rowset is: " + rowset)
                 afterSegmentCount += Integer.parseInt(rowset.split(" ")[1])
             }
+            assertEquals(afterSegmentCount, 1)
         }
-        assertEquals(afterSegmentCount, 1)
+
     }
 
     double localIndexSize = 0