f

be/src/runtime/workload_group/workload_group_manager.cpp

@@ -419,7 +419,7 @@ void WorkloadGroupMgr::handle_paused_queries() {
         // TODO: 0.2 should be a workload group properties. For example, the group is optimized for load,then the value
         // should be larged, if the group is optimized for query, then the value should be smaller.
         int64_t max_wg_memtable_bytes =
-                std::max<int64_t>(100 * 1024 * 1024, (int64_t)wg_high_water_mark_limit * 0.2);
+                std::max<int64_t>(100 * 1024 * 1024, (int64_t)(wg_high_water_mark_limit * 0.2));
         if (memtable_active_bytes + memtable_write_bytes + memtable_flush_bytes >
             max_wg_memtable_bytes) {
             // There are many table in flush queue, just waiting them flush finished.
@@ -431,8 +431,8 @@ void WorkloadGroupMgr::handle_paused_queries() {
                 continue;
             } else {
                 // Flush 50% active bytes, it means flush some memtables(currently written) to flush queue.
-                memtable_limiter->flush_workload_group_memtables(wg->id(),
-                                                                 memtable_active_bytes * 0.5);
+                memtable_limiter->flush_workload_group_memtables(
+                        wg->id(), (int64_t)(memtable_active_bytes * 0.5));
                 LOG_EVERY_T(INFO, 60)
                         << wg->name() << " load memtable size is: " << memtable_active_bytes << ", "
                         << memtable_write_bytes << ", " << memtable_flush_bytes