luoyuxia commented on PR #1941:
URL: https://github.com/apache/fluss/pull/1941#issuecomment-3654554498
> Hi @luoyuxia some observations on the obtainSecurityToken functionality.
>
> I do receive the tokens when I read fluss data as a client
>
> ```dockerfile
> try (LogScanner logScanner = table.newScan().createLogScanner()) {
> logScanner.subscribeFromBeginning(1);
> var record = logScanner.poll(Duration.ofSeconds(10));
> record.forEach(r -> _ );
> }
> ```
>
> Once log scanner is started the tokens start to be sent. However I could
not see the tokens being shared above fluss components (tablet-server
coordinator server). Similar to what happens with Flink JobManager tokens
delegated to the TaskManager. My assumption was that the token is shared among
the fluss components then it is used with a hadoop custom provider type
(Depends on the hadoop driver).
Hi, the security token is not shared above fluss components. Currently, it's
only used by fluss-client, fluss-client require a token to read from remote
directly.
--
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]
