jt2594838 commented on code in PR #15684:
URL: https://github.com/apache/iotdb/pull/15684#discussion_r2142213762
##########
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/pipeconsensus/PipeConsensusAsyncConnector.java:
##########
@@ -616,7 +617,7 @@ private void retryTransfer(final PipeDeleteDataNodeEvent
deleteDataNodeEvent) {
* @param event event to retry
*/
@SuppressWarnings("java:S899")
- public void addFailureEventToRetryQueue(final EnrichedEvent event) {
+ public synchronized void addFailureEventToRetryQueue(final EnrichedEvent
event) {
Review Comment:
So what. If there is something to be transferred, why can't we transfer it?
--
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]
