More logging to check changes are picked up 2.

airbytehq · Oct 10, 2023 · f800d70 · f800d70
1 parent 64099b3
commit f800d70
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/...re/src/main/java/io/airbyte/cdk/integrations/destination_async/buffers/BufferDequeue.java b/...re/src/main/java/io/airbyte/cdk/integrations/destination_async/buffers/BufferDequeue.java
@@ -19,6 +19,8 @@
 import java.util.concurrent.ConcurrentMap;
 import java.util.concurrent.atomic.AtomicLong;
 import java.util.concurrent.locks.ReentrantLock;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 /**
  * Represents the minimal interface over the underlying buffer queues required for dequeue
@@ -30,6 +32,9 @@
 // todo (cgardens) - make all the metadata methods more efficient.
 public class BufferDequeue {
 
+  private static final Logger LOGGER = LoggerFactory.getLogger(BufferDequeue.class);
+
+
   private final GlobalMemoryManager memoryManager;
   private final ConcurrentMap<StreamDescriptor, StreamAwareQueue> buffers;
   private final GlobalAsyncStateManager stateManager;
@@ -74,6 +79,10 @@ public MemoryAwareMessageBatch take(final StreamDescriptor streamDescriptor, fin
         }
       }
 
+      LOGGER.info("TAKE QUEUE");
+      LOGGER.info(String.valueOf(queue.size()));
+      LOGGER.info(streamDescriptor.getName());
+
       memoryManager.ghettoLog(String.format("Take queue size is: %d, name - %s | %s", queue.size(), "" + streamDescriptor.getNamespace(), streamDescriptor.getName()));
 
       if (queue.isEmpty()) {