You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@asterixdb.apache.org by AsterixDB Code Review <do...@asterix-gerrit.ics.uci.edu> on 2024/07/04 04:25:56 UTC
Change in asterixdb[master]: WIP: object pool for kafka record
From Ritik Raj <ra...@gmail.com>:
Ritik Raj has uploaded this change for review. ( https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/18426 )
Change subject: WIP: object pool for kafka record
......................................................................
WIP: object pool for kafka record
Change-Id: I0ac57c4c2671862a52cc6eebea188e6f9af6db52
---
M asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/dataflow/FeedRecordDataFlowController.java
1 file changed, 11 insertions(+), 0 deletions(-)
git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb refs/changes/26/18426/1
diff --git a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/dataflow/FeedRecordDataFlowController.java b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/dataflow/FeedRecordDataFlowController.java
index 5de2717..705acf8 100644
--- a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/dataflow/FeedRecordDataFlowController.java
+++ b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/dataflow/FeedRecordDataFlowController.java
@@ -96,6 +96,8 @@
if (!parseAndForward(record)) {
failedRecordsCount++;
}
+ // should be safe to reset, as the record has been processed.
+ record.reset();
}
} catch (HyracksDataException e) {
logFailure(e);
--
To view, visit https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/18426
To unsubscribe, or for help writing mail filters, visit https://asterix-gerrit.ics.uci.edu/settings
Gerrit-Project: asterixdb
Gerrit-Branch: master
Gerrit-Change-Id: I0ac57c4c2671862a52cc6eebea188e6f9af6db52
Gerrit-Change-Number: 18426
Gerrit-PatchSet: 1
Gerrit-Owner: Ritik Raj <ra...@gmail.com>
Gerrit-MessageType: newchange