-
Notifications
You must be signed in to change notification settings - Fork 1.2k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
avoid race condition for awaiting signals and process instance completed #2403
avoid race condition for awaiting signals and process instance completed #2403
Conversation
e8834bc
to
51536cf
Compare
} | ||
} catch (org.drools.persistence.api.SessionNotFoundException ex) { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This needs to catch org.kie.internal.runtime.manager.SessionNotFoundException
in my tests:
ERROR [org.kie.server.services.jbpm.kafka.KafkaServerConsumer] (pool-18-thread-10) Exception deserializing event: org.kie.internal.runtime.manager.SessionNotFoundException: No session found for context 143
at org.jbpm.runtime.manager.impl.PerProcessInstanceRuntimeManager$PerProcessInstanceInitializer.initKieSession(PerProcessInstanceRuntimeManager.java:584)
at org.jbpm.runtime.manager.impl.RuntimeEngineImpl.internalGetKieSession(RuntimeEngineImpl.java:169)
at org.jbpm.runtime.manager.impl.RuntimeEngineImpl.getKieSession(RuntimeEngineImpl.java:76)
at org.jbpm.runtime.manager.impl.PerProcessInstanceRuntimeManager.signalEvent(PerProcessInstanceRuntimeManager.java:186)
at org.jbpm.kie.services.impl.ProcessServiceImpl.signalEvent(ProcessServiceImpl.java:383)
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
added that exception
} | ||
} catch (org.drools.persistence.api.SessionNotFoundException ex) { | ||
logger.warn("Signal event cannot proceed because of session not found exception {} for engine {}", ex.getMessage(), runtimeEngine.getKieSessionId()); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I see this getting logged frequently and think it would be better to have it at DEBUG level.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
set to debug
… and process instance completed
51536cf
to
3957069
Compare
Quality Gate passedIssues Measures |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM, thanks @elguardian
… and process instance completed (#2403)
… and process instance completed (kiegroup#2403)
issue: https://github.com/apache/incubator-kie-issues-1016