Hi, flink community!
I am trying to do some work on renewing DelegationToken periodically for
DelegtionTokenManager, and met some problems.
1. Implementations of DelegationTokenProvider
There seems to be only two implementations for testing defined by SPI
service: TestDelegationTokenProvider and
ExceptionThrowingDelegationTokenProvider, no hdfs or hbase.
2. RPCGateway
When the renewer thread of DelegationTokenManager in resource manager
renews tokens of all providers periodically, DelegationTokenManager should
update the tokens of all taskmanagers by RPCGateway that seems to be the
appropriate way for now.
But the registered taskmanagers are managed by TaskExecutorManager in RM which
DelegationTokenManager don't have the pointer of.
So, how about using a global context to hold all necessary services, e.g.
RPCService, TaskExecutorManager or HA?
In my mind, RPCGateway seems to be a little clunky(just privately) for
extentions, why not thinking of the async typed message model between driver
and worker in design?
Thanks for any replies.
Best Regards!
