File tree Expand file tree Collapse file tree 1 file changed +2
-1
lines changed
phoenix-core-server/src/main/java/org/apache/phoenix/replication Expand file tree Collapse file tree 1 file changed +2
-1
lines changed Original file line number Diff line number Diff line change @@ -289,7 +289,7 @@ protected void processNewFilesForRound(ReplicationRound replicationRound) throws
289289 }
290290
291291 /**
292- * Processes all files in the in-progress directory.
292+ * Processes all files (older than 1 round time) in the in-progress directory.
293293 * Continuously processes files until no in-progress files remain.
294294 * @throws IOException if there's an error during file processing
295295 */
@@ -309,6 +309,7 @@ protected void processInProgressDirectory() throws IOException {
309309 files = replicationLogTracker .getOlderInProgressFiles (oldestTimestampToProcess );
310310 }
311311 long duration = EnvironmentEdgeManager .currentTime () - startTime ;
312+ LOG .info ("Finished in-progress files processing in {}ms" , duration );
312313 getMetrics ().updateTimeToProcessInProgressFiles (duration );
313314 }
314315
You can’t perform that action at this time.
0 commit comments