Savonitar commented on code in PR #28639:
URL: https://github.com/apache/flink/pull/28639#discussion_r3903743774
##########
flink-runtime/src/main/java/org/apache/flink/runtime/security/token/DefaultDelegationTokenManager.java:
##########
@@ -139,12 +240,15 @@ public DefaultDelegationTokenManager(
private Map<String, DelegationTokenProvider> loadProviders() {
LOG.info("Loading delegation token providers");
+ // Handed to every provider so it can request an immediate re-obtain
later, from any
+ // thread, decoupled from the registerJob call stack.
+ final DelegationTokenManagerCallback callback =
this::reobtainDelegationTokens;
Map<String, DelegationTokenProvider> providers = new HashMap<>();
Consumer<DelegationTokenProvider> loadProvider =
(provider) -> {
try {
if (isProviderEnabled(configuration,
provider.serviceName())) {
- provider.init(configuration);
+ provider.init(configuration, callback);
Review Comment:
I can assume, you meant local variable? I removed it and inlined method ref
in
https://github.com/apache/flink/pull/28639/changes/678106185b9f79b21d8cb682fa885ffbfb97beb8
--
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]
