From 8578edc939d3970dddd004e5d8186c63a9fdfc2d Mon Sep 17 00:00:00 2001
From: sevev <qiangzh95@gmail.com>
Date: Thu, 16 Jan 2025 16:01:14 +0800
Subject: [PATCH] update

Signed-off-by: sevev <qiangzh95@gmail.com>
---
 be/src/common/config.h             | 1 -
 be/src/exec/tablet_sink_sender.cpp | 9 +--------
 be/src/runtime/exec_env.cpp        | 1 +
 3 files changed, 2 insertions(+), 9 deletions(-)

diff --git a/be/src/common/config.h b/be/src/common/config.h
index 727fc471ddbd7..9a2570f806629 100644
--- a/be/src/common/config.h
+++ b/be/src/common/config.h
@@ -1538,5 +1538,4 @@ CONF_mInt32(json_parse_many_batch_size, "1000000");
 CONF_mBool(enable_dynamic_batch_size_for_json_parse_many, "true");
 CONF_mInt32(put_combined_txn_log_thread_pool_num_max, "64");
 CONF_mBool(enable_put_combinded_txn_log_parallel, "false");
-CONF_mBool(output_combined_txn_log, "false");
 } // namespace starrocks::config
diff --git a/be/src/exec/tablet_sink_sender.cpp b/be/src/exec/tablet_sink_sender.cpp
index 1981209d8dc77..efcf41b35eed4 100644
--- a/be/src/exec/tablet_sink_sender.cpp
+++ b/be/src/exec/tablet_sink_sender.cpp
@@ -372,20 +372,13 @@ bool TabletSinkSender::get_immutable_partition_ids(std::set<int64_t>* partition_
 Status TabletSinkSender::_write_combined_txn_log() {
     int64_t t_start = MonotonicMillis();
     if (config::enable_put_combinded_txn_log_parallel) {
-        Status st = write_combined_txn_log(_txn_log_map);
-        if (config::output_combined_txn_log) {
-            LOG(INFO) << "write_combined_txn_log parallel cost time: " << MonotonicMillis() - t_start;
-        }
-        return st;
+        return write_combined_txn_log(_txn_log_map);
     }
 
     for (const auto& [partition_id, logs] : _txn_log_map) {
         (void)partition_id;
         RETURN_IF_ERROR(write_combined_txn_log(logs));
     }
-    if (config::output_combined_txn_log) {
-        LOG(INFO) << "write_combined_txn_log non-parallel cost time: " << MonotonicMillis() - t_start;
-    }
     return Status::OK();
 }
 
diff --git a/be/src/runtime/exec_env.cpp b/be/src/runtime/exec_env.cpp
index 07d66a9bd2c03..5828677b2aa81 100644
--- a/be/src/runtime/exec_env.cpp
+++ b/be/src/runtime/exec_env.cpp
@@ -759,6 +759,7 @@ void ExecEnv::destroy() {
     SAFE_DELETE(_lake_update_manager);
     SAFE_DELETE(_lake_replication_txn_manager);
     SAFE_DELETE(_cache_mgr);
+    SAFE_DELETE(_put_combined_txn_log_thread_pool);
     _dictionary_cache_pool.reset();
     _automatic_partition_pool.reset();
     _metrics = nullptr;