Improve robustness of JdbcExecutor by safely handling multiple consumers#712
Improve robustness of JdbcExecutor by safely handling multiple consumers#712mohit-devlogs wants to merge 1 commit intoapache:mainfrom
Conversation
|
How is this PR related to #711 ? It seems they both server the same purpose, no? |
The fix for the bug is implemented in the PR #711. The fix for the bug is implemented in the same way as in the |
This PR makes the JdbcExecutor more robust by removing the faulty use of
WayangCollections.getSingle() in the function findJdbcExecutionOperatorTaskInStage().
The faulty function could potentially throw an exception if there were zero or
multiple consumers on the channel. This could cause the following runtime errors:
"[] is not a singleton"
This change will guarantee that the function now checks the number of consumers
before trying to access them, returning null if it doesn’t match the execution
pattern.
This is a status quo change, removing unneeded runtime errors in the JDBC
execution path.