[JBPM-10144] Flush TimerMappingInfo persist operation early to avoid …

…stale timers (#2250)
kiegroup · Jun 2, 2023 · 40d47b3 · 40d47b3
1 parent 6705928
commit 40d47b3
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/jbpm-runtime-manager/src/main/java/org/jbpm/runtime/manager/impl/AbstractRuntimeManager.java b/jbpm-runtime-manager/src/main/java/org/jbpm/runtime/manager/impl/AbstractRuntimeManager.java
@@ -254,7 +254,8 @@ public void fireTimerScheduled(JobHandle jobHandle) {
                         }
                     }
                     em.persist(info);
-                    logger.debug("Created Timer Mapping Info for {}", info);
+                    em.flush();
+                    logger.debug("Created Timer Mapping Info for {} and flushed to DB", info);
                 } finally {
                     em.close();
                 }