mohit-devlogs opened a new pull request, #712: URL: https://github.com/apache/wayang/pull/712
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. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
