This is an automated email from the ASF dual-hosted git repository.
lingmiao pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-doris.git
The following commit(s) were added to refs/heads/master by this push:
new 70c7281 [Routine Load] Fix bug that history routine load jobs are
cleaned prematurely
new 1f0ea2d Merge pull request #2765 from
morningman/routine_load_clean_label
70c7281 is described below
commit 70c7281bf22f5689add0e86777b746fcc26a88f6
Author: morningman <[email protected]>
AuthorDate: Wed Jan 15 11:18:34 2020 +0800
[Routine Load] Fix bug that history routine load jobs are cleaned
prematurely
---
fe/src/main/java/org/apache/doris/load/routineload/RoutineLoadJob.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/fe/src/main/java/org/apache/doris/load/routineload/RoutineLoadJob.java
b/fe/src/main/java/org/apache/doris/load/routineload/RoutineLoadJob.java
index 4fdedf2..655c5af 100644
--- a/fe/src/main/java/org/apache/doris/load/routineload/RoutineLoadJob.java
+++ b/fe/src/main/java/org/apache/doris/load/routineload/RoutineLoadJob.java
@@ -1154,7 +1154,7 @@ public abstract class RoutineLoadJob extends
AbstractTxnStateChangeCallback impl
return false;
}
Preconditions.checkState(endTimestamp != -1, endTimestamp);
- if ((System.currentTimeMillis() - endTimestamp) >
Config.label_clean_interval_second * 1000) {
+ if ((System.currentTimeMillis() - endTimestamp) >
Config.label_keep_max_second * 1000) {
return true;
}
return false;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
