Как направить группу в очередь, чтобы указать очередь c пряжи через Ambari? - PullRequest
0 голосов
/ 17 июня 2020

Я могу успешно перенаправить пользователя в заданную очередь c, используя ambari. Синтаксис, который я использую для пользователя:

u:hive:prod

Однако мне не удается сделать это для группы.

Синтаксис, который я использую для группы:

g:datascience:dev

На граничном узле у меня есть группа под названием datascience, содержащая пользователя scientist

$ groups scientist
scientist : scientist datascience

Когда я отправляю команду beeline с этим пользователем (скажем, insert into default.routingtest values (0, "test")), я появляется следующее сообщение об ошибке:

ИНФОРМАЦИЯ: Ошибка отправки Dag из-за организации. apache .had oop .yarn.exceptions.YarnException: не удалось отправить приложение application_1592385599162_0001, отправленное ученым-пользователем Причина: Группы для ученого-пользователя в орг. apache .had oop .yarn.server.resourcemanager.placement.UserGroupMappingPlacementRule.getPlacementForApp (UserGroupMappingPlacementRule. java: 210) в орг. apache .had oop не найдены. yarn.server.resourcemanager.placement.PlacementManager.placeApplication (PlacementManager. java: 67) в org. apache .had oop .yarn.server.resourcemanager.RMAppManager.placeApplication (RMAppManager. java: 791) в орг. apache .had oop .yarn.s erver.resourcemanager.RMAppManager.createAndPopulateNewRMApp (RMAppManager. java: 368) в org. apache .had oop .yarn.server.resourcemanager.RMAppManager.submitApplication (RMAppManager. java. 1040 * .had oop .yarn.server.resourcemanager.ClientRMService.submitApplication (ClientRMService. java: 645) в орг. apache .had oop .yarn.api.impl.pb.service.ApplicationClientProtocolPBServiceImpl. submitApplication (ApplicationClientProtocolPBServiceImpl. java: 277) в орг. apache .had oop .yarn.proto.ApplicationClientProtocol $ ApplicationClientProtocolService $ 2.callBlockingMethod (ApplicationClientProtocol. java: 563) в орг. * 1049 1050 * .ip c .ProtobufRpcEngine $ Server $ ProtoBufRpcInvoker.call (ProtobufRpcEngine. java: 524) в организации apache .had oop .ip c .RPC $ Server.call (RP C. java: 1025) в организации apache .had oop .ip c .Server $ RpcCall.run (Server. java: 876) в организации apache .had oop .ip c .Server $ RpcCall.run (Server. java: 822) в java .security.AccessController.doPrivileged (Native M ethod) в javax.security.auth.Subject.doAs (Subject. java: 422) в org. apache .had oop .security.UserGroupInformation.doAs (UserGroupInformation. java: 1730) в org. apache .had oop .ip c .Server $ Handler.run (Server. java: 2682)

Что вызывает эту ошибку и как ее решить?

1 Ответ

0 голосов
/ 17 июня 2020

Проблема заключалась в том, что пользователь и группа существовали не на всей машине кластера. Убедитесь, что пользователь и группа существуют на всех машинах.

...