sunchao commented on code in PR #3744:
URL: https://github.com/apache/celeborn/pull/3744#discussion_r3476314611
##########
common/src/main/java/org/apache/celeborn/common/client/MasterClient.java:
##########
@@ -74,6 +75,8 @@ public MasterClient(RpcEnv rpcEnv, CelebornConf conf, boolean
isWorker) {
}
private static final String SPLITTER = "#";
+ private static final String OUTBOX_STOPPED_MESSAGE =
Review Comment:
Fixed in eedab7ef7. I added `OutboxStoppedException extends
CelebornException`; Outbox emits it and MasterClient matches it with
`instanceof`, so there is no duplicated string contract.
--
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]
