-
Notifications
You must be signed in to change notification settings - Fork 4.5k
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
[Bug][Master] fix duplicate event, avoid event stacking #14986
[Bug][Master] fix duplicate event, avoid event stacking #14986
Conversation
Codecov Report
@@ Coverage Diff @@
## 3.1.9-prepare #14986 +/- ##
================================================
Coverage ? 38.22%
Complexity ? 3989
================================================
Files ? 1000
Lines ? 36990
Branches ? 4278
================================================
Hits ? 14138
Misses ? 21236
Partials ? 1616 📣 We’re building smart automated test selection to slash your CI/CD build times. Learn more |
SonarCloud Quality Gate failed. 14 Bugs 28.1% Coverage The version of Java (11.0.20.1) you have used to run this analysis is deprecated and we will stop accepting it soon. Please update to at least Java 17. Catch issues before they fail your Quality Gate with our IDE extension SonarLint |
import java.util.Optional; | ||
import java.util.concurrent.ConcurrentLinkedQueue; | ||
|
||
import javax.annotation.PostConstruct; | ||
|
||
import lombok.NonNull; |
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.
The code style is broken.
This reverts commit 7a38b87.
Purpose of the pull request
When run a DAG which include more than 400+ sub process tasks,
StateWheelExecuteThread
will create 400+ events every 5s, andWorkflowExecuteRunnable
will sleep 1s when handle event error, which cause event stacking.BTW, it was fixed by pr #13948 so it dont have to fix in dev and 320.
Brief change log
WorkflowExecuteRunnable
queue.Verify this pull request