fix: compactor with block org (#2646)

src/ingester/src/writer.rs

@@ -209,7 +209,7 @@ impl Writer {
                     Arc::new(immutable::Immutable::new(thread_id, key.clone(), old_mem)),
                 );
                 log::info!(
-                    "[INGESTER:WAL] done add to IMMUTABLES, file: {}/{}/{}/{}.wal",
+                    "[INGESTER:WAL] done  add to IMMUTABLES, file: {}/{}/{}/{}.wal",
                     thread_id,
                     &key.org_id,
                     &key.stream_type,

src/service/compact/mod.rs

@@ -173,6 +173,13 @@ pub async fn run_merge() -> Result<(), anyhow::Error> {
         StreamType::Metadata,
     ];
     for org_id in orgs {
+        // check backlist
+        if !db::file_list::BLOCKED_ORGS.is_empty()
+            && db::file_list::BLOCKED_ORGS.contains(&org_id.as_str())
+        {
+            continue;
+        }
+
         // get the working node for the organization
         let (_, node) = db::compact::organization::get_offset(&org_id, "merge").await;
         if !node.is_empty() && LOCAL_NODE_UUID.ne(&node) && get_node_by_uuid(&node).is_some() {