Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
[fix](stream load) do not throw exception but skip record when can no…
…t find database (#39360) (#39531) pick (#39360) When fetch stream load record from BE node, if can not find database, StreamLoadRecordMgr will throw exception and the remaining records will not be recorded in memory. For example: Ten stream load records were pulled, and the database associated with the stream load of the first record was deleted by the user. Therefore, the pull will end, resulting in the remaining nine records not being consumed recorded in memory. This pr do not throw exception but skip record when can not find database to solve this problem.
- Loading branch information