celeborn/worker
SteNicholas 55e85055b8
[CELEBORN-771][FLINK] Convert PushDataHandShake, RegionFinish, RegionStart to PB
### What changes were proposed in this pull request?

`PushDataHandShake`, `RegionFinish`, and `RegionStart` should merge to transport messages to enhance celeborn's compatibility.

### Why are the changes needed?

1. Improves celeborn's transport flexibility to change RPC.
2. Makes Compatible with 0.2 client.

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

No.

### How was this patch tested?

- `RemoteShuffleOutputGateSuiteJ`

Closes #1910 from SteNicholas/CELEBORN-771.

Authored-by: SteNicholas <programgeek@163.com>
Signed-off-by: mingji <fengmingxiao.fmx@alibaba-inc.com>
2023-09-22 11:36:45 +08:00
..
src [CELEBORN-771][FLINK] Convert PushDataHandShake, RegionFinish, RegionStart to PB 2023-09-22 11:36:45 +08:00
pom.xml [CELEBORN-977] Support RocksDB as recover DB backend 2023-09-19 09:20:33 +08:00