XComp commented on a change in pull request #15131:
URL: https://github.com/apache/flink/pull/15131#discussion_r623782754



##########
File path: 
flink-core/src/main/java/org/apache/flink/configuration/SecurityOptions.java
##########
@@ -108,6 +108,20 @@
                                     + " (for example, `Client,KafkaClient` to 
use the credentials for ZooKeeper authentication and for"
                                     + " Kafka authentication)");
 
+    @Documentation.Section(Documentation.Sections.SECURITY_AUTH_KERBEROS)
+    public static final ConfigOption<Boolean> KERBEROS_FETCH_DELEGATION_TOKEN =
+            key("security.kerberos.fetch.delegation-token")
+                    .booleanType()
+                    .defaultValue(true)
+                    .withDescription(
+                            "Indicates whether to fetch the delegation tokens 
for external services the Flink job needs to contact. "
+                                    + "Only HDFS and HBase are supported. It 
is used in Yarn deployments. "
+                                    + "If true, Flink will fetch HDFS and 
HBase delegation tokens and inject them into Yarn AM containers.  "

Review comment:
       ```suggestion
                                       + "If true, Flink will fetch HDFS and 
HBase delegation tokens and inject them into Yarn AM containers. "
   ```




-- 
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.

For queries about this service, please contact Infrastructure at:
[email protected]


Reply via email to