Re: [PR] [CELEBORN-1558] Fix the incorrect decrement of pendingWrites in handlePushMergeData [celeborn]

["RexXiong (via GitHub)" <gi...@apache.org>]

RexXiong commented on code in PR #2677:
URL: https://github.com/apache/celeborn/pull/2677#discussion_r1713262326


##########
worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/PartitionDataWriter.java:
##########
@@ -566,7 +566,7 @@ protected void waitOnNoPending(AtomicInteger counter) throws IOException {
       waitTime -= WAIT_INTERVAL_MS;
     }
     if (counter.get() > 0) {
-      IOException ioe = new IOException("Wait pending actions timeout.");
+      IOException ioe = new IOException("Wait pending actions timeout, Counter: " + counter.get());

Review Comment:
   Pending actions have two types: numPendingWrites and numPendingFlushes, So I use counter 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: issues-unsubscribe@celeborn.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org