Skip to content

Commit c506b4a

Browse files
authored
[bug](cooldown)add config for Cooldown Job
1 parent 241a956 commit c506b4a

2 files changed

Lines changed: 16 additions & 10 deletions

File tree

fe/fe-core/src/main/java/org/apache/doris/cooldown/CooldownHandler.java

Lines changed: 12 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -136,18 +136,22 @@ protected void runAfterCatalogReady() {
136136
}
137137

138138
public void write(DataOutput out) throws IOException {
139-
out.writeInt(runableCooldownJobs.size());
140-
for (CooldownJob cooldownJob : runableCooldownJobs.values()) {
141-
cooldownJob.write(out);
139+
if (Config.cooldown_single_remote_file) {
140+
out.writeInt(runableCooldownJobs.size());
141+
for (CooldownJob cooldownJob : runableCooldownJobs.values()) {
142+
cooldownJob.write(out);
143+
}
142144
}
143145
}
144146

145147
public void readField(DataInput in) throws IOException {
146-
if (Env.getCurrentEnvJournalVersion() >= FeMetaVersion.VERSION_115) {
147-
int size = in.readInt();
148-
for (int i = 0; i < size; i++) {
149-
CooldownJob cooldownJob = CooldownJob.read(in);
150-
replayCooldownJob(cooldownJob);
148+
if (Config.cooldown_single_remote_file) {
149+
if (Env.getCurrentEnvJournalVersion() >= FeMetaVersion.VERSION_115) {
150+
int size = in.readInt();
151+
for (int i = 0; i < size; i++) {
152+
CooldownJob cooldownJob = CooldownJob.read(in);
153+
replayCooldownJob(cooldownJob);
154+
}
151155
}
152156
}
153157
}

fe/fe-core/src/main/java/org/apache/doris/persist/EditLog.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -721,8 +721,10 @@ public static void loadJournal(Env env, JournalEntity journal) {
721721
break;
722722
}
723723
case OperationType.OP_PUSH_COOLDOWN_CONF:
724-
CooldownJob cooldownJob = (CooldownJob) journal.getData();
725-
env.getCooldownHandler().replayCooldownJob(cooldownJob);
724+
if (Config.cooldown_single_remote_file) {
725+
CooldownJob cooldownJob = (CooldownJob) journal.getData();
726+
env.getCooldownHandler().replayCooldownJob(cooldownJob);
727+
}
726728
break;
727729
case OperationType.OP_BATCH_ADD_ROLLUP: {
728730
BatchAlterJobPersistInfo batchAlterJobV2 = (BatchAlterJobPersistInfo) journal.getData();

0 commit comments

Comments
 (0)