Fix

kssenii · Oct 17, 2023 · 8744cd9 · 8744cd9
1 parent 96c518b
commit 8744cd9
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/Storages/S3Queue/S3QueueFilesMetadata.cpp b/src/Storages/S3Queue/S3QueueFilesMetadata.cpp
@@ -474,7 +474,7 @@ void S3QueueFilesMetadata::setFileProcessedForUnorderedMode(ProcessingNodeHolder
     if (holder->remove(&requests, &responses))
     {
         LOG_TEST(log, "Moved file `{}` to processed", path);
-        zk_client->tryRemove(node_name + ".retriable", -1);
+        zk_client->tryRemove(zookeeper_failed_path / node_name + ".retriable", -1);
         return;
     }
 
@@ -537,7 +537,7 @@ void S3QueueFilesMetadata::setFileProcessedForOrderedMode(ProcessingNodeHolderPt
         if (holder->remove(&requests, &responses))
         {
             LOG_TEST(log, "Moved file `{}` to processed", path);
-            zk_client->tryRemove(node_name + ".retriable", -1);
+            zk_client->tryRemove(zookeeper_failed_path / node_name + ".retriable", -1);
             return;
         }