This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new c506b4a1e3 [bug](cooldown)add config for Cooldown Job
c506b4a1e3 is described below
commit c506b4a1e35d49566ddcbeb06d13d08b4bc441f9
Author: pengxiangyu <[email protected]>
AuthorDate: Sat Jan 28 19:58:50 2023 +0800
[bug](cooldown)add config for Cooldown Job
---
.../org/apache/doris/cooldown/CooldownHandler.java | 20 ++++++++++++--------
.../main/java/org/apache/doris/persist/EditLog.java | 6 ++++--
2 files changed, 16 insertions(+), 10 deletions(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/cooldown/CooldownHandler.java
b/fe/fe-core/src/main/java/org/apache/doris/cooldown/CooldownHandler.java
index fe0815c370..4ad601e5f4 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/cooldown/CooldownHandler.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/cooldown/CooldownHandler.java
@@ -136,18 +136,22 @@ public class CooldownHandler extends MasterDaemon {
}
public void write(DataOutput out) throws IOException {
- out.writeInt(runableCooldownJobs.size());
- for (CooldownJob cooldownJob : runableCooldownJobs.values()) {
- cooldownJob.write(out);
+ if (Config.cooldown_single_remote_file) {
+ out.writeInt(runableCooldownJobs.size());
+ for (CooldownJob cooldownJob : runableCooldownJobs.values()) {
+ cooldownJob.write(out);
+ }
}
}
public void readField(DataInput in) throws IOException {
- if (Env.getCurrentEnvJournalVersion() >= FeMetaVersion.VERSION_115) {
- int size = in.readInt();
- for (int i = 0; i < size; i++) {
- CooldownJob cooldownJob = CooldownJob.read(in);
- replayCooldownJob(cooldownJob);
+ if (Config.cooldown_single_remote_file) {
+ if (Env.getCurrentEnvJournalVersion() >=
FeMetaVersion.VERSION_115) {
+ int size = in.readInt();
+ for (int i = 0; i < size; i++) {
+ CooldownJob cooldownJob = CooldownJob.read(in);
+ replayCooldownJob(cooldownJob);
+ }
}
}
}
diff --git a/fe/fe-core/src/main/java/org/apache/doris/persist/EditLog.java
b/fe/fe-core/src/main/java/org/apache/doris/persist/EditLog.java
index 83315e4dd7..4c359c72d7 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/persist/EditLog.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/persist/EditLog.java
@@ -721,8 +721,10 @@ public class EditLog {
break;
}
case OperationType.OP_PUSH_COOLDOWN_CONF:
- CooldownJob cooldownJob = (CooldownJob) journal.getData();
- env.getCooldownHandler().replayCooldownJob(cooldownJob);
+ if (Config.cooldown_single_remote_file) {
+ CooldownJob cooldownJob = (CooldownJob)
journal.getData();
+
env.getCooldownHandler().replayCooldownJob(cooldownJob);
+ }
break;
case OperationType.OP_BATCH_ADD_ROLLUP: {
BatchAlterJobPersistInfo batchAlterJobV2 =
(BatchAlterJobPersistInfo) journal.getData();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
