otterc commented on code in PR #2346:
URL:
https://github.com/apache/incubator-celeborn/pull/2346#discussion_r1508425200
##########
worker/src/main/scala/org/apache/celeborn/service/deploy/worker/InternalRpcEndpoint.scala:
##########
@@ -28,16 +29,19 @@ import org.apache.celeborn.common.rpc._
*/
private[celeborn] class InternalRpcEndpoint(
override val rpcEnv: RpcEnv,
- val conf: CelebornConf)
+ val conf: CelebornConf,
+ val secretRegistry: SecretRegistry)
extends RpcEndpoint with Logging {
override def onDisconnected(address: RpcAddress): Unit = {
logDebug(s"Client $address got disconnected.")
}
override def receive: PartialFunction[Any, Unit] = {
- // TODO: [CELEBORN-1234] Handle the application secret from the Master
- case _ => throw new CelebornException(self + " not implemented")
+ case pb: PbApplicationMeta =>
+ val appId = pb.getAppId
+ val secret = pb.getSecret
+ logInfo(s"Received application meta for $appId from the coordinator")
Review Comment:
We shouldn't log the secret
--
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]
