Kerberos Java Credentials Cache

Question

Я запускаю следующий код для взаимодействия с кластером hasoop, включенным в kerberos.

val t1 = new Thread() { 
      override def run() { 
       println("output of first thread") 
       val conf = new Configuration 
       conf.set("hadoop.security.authentication", "Kerberos") 
       conf.set("fs.defaultFS", "hdfs://192.168.23.206:8020") 
       UserGroupInformation.setConfiguration(conf) 
       UserGroupInformation.loginUserFromKeytab("dummy@platalyticsrealm", "E:\\\\dummy.keytab"); 
       val fs = FileSystem.get(conf); 
       val status = fs.listStatus(new Path("/")) 

       println(UserGroupInformation.getLoginUser().getShortUserName()) 
      } 
     } 
val t2 = new Thread() { 
      override def run() { 
       println("Running Thread 2") 
       val conf = new Configuration 
       conf.set("hadoop.security.authentication", "Kerberos") 
       conf.set("fs.defaultFS", "hdfs://192.168.23.206:8020") 
       UserGroupInformation.setConfiguration(conf) 
       UserGroupInformation.loginUserFromKeytab("test@platalyticsrealm", "E:\\\\test.keytab"); 
       val fs = FileSystem.get(conf); 
       val status = fs.listStatus(new Path("/")) 

       println(UserGroupInformation.getLoginUser().getShortUserName()) 

      } 
     } 
     t1.start 
     Thread.sleep(5000) 
     t2.start 

Этот код выдает следующий результат.

тест

тест

Это означает, что второй поток чрезмерно написать учетные данные, полученные с помощью первого потока. У меня есть следующие вопросы: 1. Если учетные данные хранятся в моей среде Windows. Я искал в C: \ Users \ имя пользователя, но я не нашел. 2. Как я могу решить эту проблему кеширования избыточных писем, когда несколько пользователей пытаются получить доступ к хаоу за раз.

Благодаря

Answer 1

Ваш код Java явно использует статические методы установить по умолчанию, неявный, глобальный, JVM шириной уги. Это то, что нужно людям в 99% случаев.

Но Если вам нужно обслуживать несколько сеансов для нескольких пользователей в режиме клиент-сервер, то ясно, что это невозможно. Пожалуйста, прочитайте that tutorial, выбранный случайным образом при поиске Google, в разделе «Несколько UGI». Затем сделайте некоторое исследование самостоятельно.

Если вы хотите, чтобы копаться в грязные детали реализации, вы можете заглянуть в эту awe-inspiring grimoire по парню, который на самом деле поддерживает код безопасности базы Hadoop (также коды базы Спарка и основание ZK код) и не слишком счастлив об этом.