[INLONG-10006][Agent] Return sourceData in batches

apache · Apr 18, 2024 · 263949a · 263949a
1 parent 718e972
commit 263949a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/MongoDBSource.java b/...ent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/MongoDBSource.java
@@ -157,7 +157,7 @@ protected List<SourceData> readFromSource() {
         List<SourceData> dataList = new ArrayList<>();
         try {
             int size = 0;
-            while (size <= BATCH_READ_LINE_TOTAL_LEN) {
+            while (size < BATCH_READ_LINE_TOTAL_LEN) {
                 SourceData sourceData = debeziumQueue.poll(1, TimeUnit.SECONDS);
                 if (sourceData != null) {
                     size += sourceData.getData().length;