[GitHub] [inlong] luchunliang commented on a diff in pull request #5438: [INLONG-5423][Sort] Revise invalid partition time when dispatch messages

[GitBox <gi...@apache.org>]

luchunliang commented on code in PR #5438:
URL: https://github.com/apache/inlong/pull/5438#discussion_r941941949


##########
inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/dispatch/DispatchManager.java:
##########
@@ -134,6 +143,18 @@ public void outputOvertimeData() {
                 inCounter.getAndSet(0), outCounter.getAndSet(0));
     }
 
+    /**
+     * reset dispatch time if the dispatch time is invalid.
+     * The default ahead time is 1 hour, and default delay time is 16 hours.
+     */
+    private void checkAndResetDispatchTime(DispatchProfile dispatchProfile) {
+        long cur = System.currentTimeMillis();

Review Comment:
   The code line can be before the line "removeKeys.forEach((key) -> {".
   
   long cur = System.currentTimeMillis();



-- 
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: commits-unsubscribe@inlong.apache.org

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