fix(core): fix time unit (#2092)

SCNieh · web-flow · commit c604fec97559 · 2024-10-22T16:58:51.000+08:00
Signed-off-by: Shichao Nie &lt;niesc@automq.com&gt;
diff --git a/metadata/src/main/java/org/apache/kafka/controller/stream/S3ObjectControlManager.java b/metadata/src/main/java/org/apache/kafka/controller/stream/S3ObjectControlManager.java
@@ -406,7 +406,7 @@ public ControllerResult<Void> checkS3ObjectsLifecycle() {
                 preparedObjectsTimeouts.put(obj.getObjectId(), newPreparedObjectTimeout(obj.getObjectId(), obj.getTimestamp()));
             }
         }
-        if (now - lastPreparedObjectsSwitchTimestamp > TimeUnit.HOURS.toMillis(60)) {
+        if (now - lastPreparedObjectsSwitchTimestamp > TimeUnit.MINUTES.toMillis(60)) {
             // The preparedObjectsTimeouts isn't a Timeline struct, so it's not consistent with the preparedObjects0/1.
             // Consider the following scenario:
             // 1. Prepare(obj1), add timeout check.

Original file line number	Diff line number	Diff line change
`@@ -406,7 +406,7 @@ public ControllerResult<Void> checkS3ObjectsLifecycle() {`
`406`	`406`	`preparedObjectsTimeouts.put(obj.getObjectId(), newPreparedObjectTimeout(obj.getObjectId(), obj.getTimestamp()));`
`407`	`407`	`}`
`408`	`408`	`}`
`409`		`- if (now - lastPreparedObjectsSwitchTimestamp > TimeUnit.HOURS.toMillis(60)) {`
	`409`	`+ if (now - lastPreparedObjectsSwitchTimestamp > TimeUnit.MINUTES.toMillis(60)) {`
`410`	`410`	`// The preparedObjectsTimeouts isn't a Timeline struct, so it's not consistent with the preparedObjects0/1.`
`411`	`411`	`// Consider the following scenario:`
`412`	`412`	`// 1. Prepare(obj1), add timeout check.`