fix: queue

apache · Dec 10, 2024 · 50400bc · 50400bc
1 parent 6ffacbd
commit 50400bc
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/extension/logstash/lib/logstash/outputs/doris.rb b/extension/logstash/lib/logstash/outputs/doris.rb
@@ -223,7 +223,7 @@ def handle_request(documents, http_headers, event_num, req_count)
       req_count += 1
       @logger.warn("Will do retry #{req_count} after #{sleep_for} secs.")
       timer_task = RetryTimerTask.new(@retry_queue, @count_block_queue, [documents, http_headers, event_num, req_count])
-      @count_block_queue.add(0)
+      @count_block_queue.put(0)
       @timer.schedule(timer_task, sleep_for*1000)
    end
 

diff --git a/extension/logstash/lib/logstash/util/retry_timer_task.rb b/extension/logstash/lib/logstash/util/retry_timer_task.rb
@@ -28,6 +28,6 @@ def initialize(retry_queue, count_block_queue, event)
 
    def run
       @retry_queue << @event
-      @count_block_queue.pull
+      @count_block_queue.poll
    end
 end