Caideyipi commented on code in PR #12344:
URL: https://github.com/apache/iotdb/pull/12344#discussion_r1570208783
##########
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/event/EnrichedEvent.java:
##########
@@ -148,6 +152,9 @@ public boolean decreaseReferenceCount(String holderMessage,
boolean shouldReport
Thread.currentThread().getStackTrace());
}
}
+ if (!isSuccessful) {
Review Comment:
It seems that the flag is meaningless and the "0" reference count will still
go "<0" and succeed.
##########
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/PipeReceiverStatusHandler.java:
##########
@@ -133,12 +133,14 @@ public void handle(TSStatus status, String
exceptionMessage, String recordMessag
LOGGER.warn(
"User conflict exception: will retry {}. status: {}",
- (retryMaxMillisWhenConflictOccurs == Long.MAX_VALUE ? "forever"
: "for at least ")
- + (retryMaxMillisWhenConflictOccurs
- + exceptionFirstEncounteredTime.get()
- - System.currentTimeMillis())
- / 1000.0
- + " seconds",
+ retryMaxMillisWhenConflictOccurs == Long.MAX_VALUE
Review Comment:
Personally I think keeping the "()" is clearer...
##########
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/thrift/sync/IoTDBDataRegionSyncConnector.java:
##########
@@ -182,6 +224,8 @@ private void doTransfer() {
tabletBatchBuilder.deepCopyEvents().toString());
}
+ tabletBatchBuilder.decreaseEventsReferenceCount(
+ IoTDBDataRegionSyncConnector.class.getName(), false);
Review Comment:
Why false here?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
