celeborn/master/src
Fei Wang 5dfbfd2840 [CELEBORN-1475] Fix unknownExcludedWorkers filter for /exclude request
### What changes were proposed in this pull request?

Now for unknown excluded workers filter,
```
    val unknownExcludedWorkers =
      (workersToAdd ++ workersToRemove).filter(!statusSystem.workers.contains(_))
```

The `workersToAdd` and `workersToRemove` are in `Array[String]` type, and `statusSystem.workers` is in `Set<WorkerInfo>` type.

In this pr,  `workersToAdd` and `workersToRemove` is in `List[WorkerInfo]` type.

### Why are the changes needed?

As title.

### Does this PR introduce _any_ user-facing change?
No.

### How was this patch tested?

Closes #2586 from turboFei/fix_work_filter.

Authored-by: Fei Wang <fwang12@ebay.com>
Signed-off-by: SteNicholas <programgeek@163.com>
2024-06-23 03:43:18 +08:00
..
main [CELEBORN-1475] Fix unknownExcludedWorkers filter for /exclude request 2024-06-23 03:43:18 +08:00
test [CELEBORN-1318] Support celeborn http authentication 2024-06-20 10:35:12 +08:00