2

apache · Mar 28, 2024 · be3d7da · be3d7da
1 parent 2039016
commit be3d7da
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 23 deletions.
diff --git a/be/src/runtime/exec_env_init.cpp b/be/src/runtime/exec_env_init.cpp
@@ -171,7 +171,6 @@ Status ExecEnv::_init(const std::vector<StorePath>& store_paths) {
     _file_meta_cache = new FileMetaCache(config::max_external_file_meta_cache_num);
 
     _dns_cache = new DNSCache();
-    _spill_stream_mgr = new vectorized::SpillStreamManager(spill_store_paths);
     _backend_client_cache->init_metrics("backend");
     _frontend_client_cache->init_metrics("frontend");
     _broker_client_cache->init_metrics("broker");

diff --git a/fe/fe-core/src/main/java/org/apache/doris/catalog/Env.java b/fe/fe-core/src/main/java/org/apache/doris/catalog/Env.java
@@ -691,15 +691,7 @@ private Env(boolean isCheckpointCatalog) {
         this.binlogManager = new BinlogManager();
         this.binlogGcer = new BinlogGcer();
         this.columnIdFlusher = new ColumnIdFlushDaemon();
-<<<<<<< HEAD
-=======
-        this.queryCancelWorker = new QueryCancelWorker(systemInfo);
-        this.topicPublisherThread = new TopicPublisherThread(
-                "TopicPublisher", Config.publish_topic_info_interval_ms, systemInfo);
-        this.mtmvService = new MTMVService();
-        this.insertOverwriteManager = new InsertOverwriteManager();
         this.dnsCache = new DNSCache();
->>>>>>> 39d695c05c ([opt](fqdn) Add DNS Cache for FE and BE (#32869))
     }
 
     public static void destroyCheckpoint() {
@@ -1549,13 +1541,8 @@ private void startMasterOnlyDaemonThreads() {
         columnIdFlusher.start();
     }
 
-<<<<<<< HEAD
     // start threads that should running on all FE
     private void startNonMasterDaemonThreads() {
-=======
-    // start threads that should run on all FE
-    protected void startNonMasterDaemonThreads() {
->>>>>>> 39d695c05c ([opt](fqdn) Add DNS Cache for FE and BE (#32869))
         // start load manager thread
         loadManager.start();
         tabletStatMgr.start();
@@ -1565,16 +1552,7 @@ protected void startNonMasterDaemonThreads() {
         getInternalCatalog().getEsRepository().start();
         // domain resolver
         domainResolver.start();
-<<<<<<< HEAD
-=======
-        // fe disk updater
-        feDiskUpdater.start();
-        if (Config.enable_hms_events_incremental_sync) {
-            metastoreEventsProcessor.start();
-        }
-
         dnsCache.start();
->>>>>>> 39d695c05c ([opt](fqdn) Add DNS Cache for FE and BE (#32869))
     }
 
     private void transferToNonMaster(FrontendNodeType newType) {