Leo Li
Leo Li
### What changes were proposed in this pull request? When build the open stream request, additionally check whether the host is equivalent to judge whether to read locally. ### Why...
### What changes were proposed in this pull request? For spark3 client, use a long variable to help to count written records instead of a `tmpRecords` array. ### Why are...
### Description of PR When scheduling asynchronously using Capacity Scheduler, the traversing indexs in `CapacityScheduler#schedule` will always contains `start` index twice. This may not in line with the original intention...