Skip to content

Commit e1ad147

Browse files
authored
fix app scheduling (#24449)
1 parent 358becc commit e1ad147

File tree

1 file changed

+6
-4
lines changed

1 file changed

+6
-4
lines changed

openmetadata-service/src/main/java/org/openmetadata/service/apps/ApplicationHandler.java

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -305,8 +305,9 @@ public void migrateQuartzConfig(App application) throws SchedulerException {
305305
appRepository.getUpdater(currentApp, updatedApp, EntityRepository.Operation.PATCH, null);
306306
updater.update();
307307
AppScheduler.getInstance().deleteScheduledApplication(updatedApp);
308-
AppScheduler.getInstance().scheduleApplication(updatedApp);
309-
LOG.info("migrated app configuration for {}", application.getName());
308+
LOG.info(
309+
"migrated app configuration for {}, will be rescheduled by install()",
310+
application.getName());
310311
}
311312

312313
public void fixCorruptedInstallation(App application) throws SchedulerException {
@@ -323,10 +324,11 @@ public void fixCorruptedInstallation(App application) throws SchedulerException
323324
}
324325
String appName = jobDataMap.getString(APP_NAME);
325326
if (appName == null) {
326-
LOG.info("corrupt entry for app {}, reinstalling", application.getName());
327+
LOG.info(
328+
"corrupt entry for app {}, deleting corrupt job. Will be rescheduled by install()",
329+
application.getName());
327330
App app = appRepository.getDao().findEntityByName(application.getName());
328331
AppScheduler.getInstance().deleteScheduledApplication(app);
329-
AppScheduler.getInstance().scheduleApplication(app);
330332
}
331333
}
332334

0 commit comments

Comments
 (0)