[
https://issues.apache.org/jira/browse/HUDI-2402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17411660#comment-17411660
]
ASF GitHub Bot commented on HUDI-2402:
--------------------------------------
test-wangxiaoyu commented on a change in pull request #3622:
URL: https://github.com/apache/hudi/pull/3622#discussion_r704001915
##########
File path:
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/DataSourceOptions.scala
##########
@@ -191,6 +191,16 @@ object DataSourceWriteOptions {
.withAlternatives("hoodie.datasource.write.storage.type")
.withDocumentation("The table type for the underlying data, for this
write. This can’t change between writes.")
+ val HIVE_SYNC_USE_KERBEROS: ConfigProperty[Boolean] = ConfigProperty
+ .key("hoodie.datasource.hive_sync.use_kerberos")
+ .defaultValue(false)
+ .withDocumentation("Whether to use Kerberos authentication.")
+
+ val HIVE_SYNC_KERBEROS_PRINCIPAL: ConfigProperty[String] = ConfigProperty
+ .key("hive_sync.kerberos_principal")
+ .noDefaultValue()
Review comment:
Has been adjusted
--
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]
> Hive Sync supports Kerberos authentication
> ------------------------------------------
>
> Key: HUDI-2402
> URL: https://issues.apache.org/jira/browse/HUDI-2402
> Project: Apache Hudi
> Issue Type: Improvement
> Components: Flink Integration, Hive Integration
> Reporter: 王晓宇
> Priority: Critical
> Labels: pull-request-available
> Fix For: 0.9.0
>
> Original Estimate: 3h
> Remaining Estimate: 3h
>
> For Hive with Kerberos enabled, THE HMS of HUDI cannot access the Hive
> metadata
> Hive.get(configuration).getMSC()
> Methods before
> Perform Kerberos authentication on the Flink client
> Set the parameters for enabling Kerberos authentication and the configuration
> parameters for transmitting hive Principal to Hive
> I added two parameters
> 1.hive_sync.use_kerberos
> 2.hive_sync.kerberos_principal
> Use the following method to enable Hive Kerberos access control
> CREATE TABLE t2(
> Uuid VARCHAR (20),
> The name VARCHAR (10),
> The age INT,
> Ts TIMESTAMP (3),
> ` partition ` VARCHAR (20)
> )
> PARTITIONED BY (`partition`)
> with(
> 'connector' = 'hudi',
> 'hive_sync.enable'='true',
> 'hive_sync.db'='test',
> 'hive_sync.table'='t2',
> 'hive_sync.mode'='hms',
> 'path' = 'hdfs://ip:8020/warehouse/hudi/t2',
> 'hive_sync.metastore.uris'='thrift://ip:9083',
> 'hive_sync.use_kerberos' = 'true',
> 'hive_sync.kerberos_principal' = 'hive/_HOST@BIGDATA'
> )
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
