Support Questions
Find answers, ask questions, and share your expertise
Announcements
Alert: Welcome to the Unified Cloudera Community. Former HCC members be sure to read and learn how to activate your account here.

Atlas does not sync hive tables and Altas tags does not show in Ranger

Highlighted

Atlas does not sync hive tables and Altas tags does not show in Ranger

New Contributor

Atlas, Hive,Ranger services are running fine. But when a new table is created in Atlas. When a new tag is created in Atlas, its not showing up in Ranger when creating a new Tag based policy. Tries to test with Kafka, but it does not work. /usr/hdp/current/kafka-broker/bin/kafka-consumer-groups.sh --bootstrap-server locahost:6667 --new-consumer --group groupname --describe --security-protocol SASL_SSL Error message WARN Failed to send SSL Close message (org.apache.kafka.common.network.SslTransportLayer) java.io.IOException: Broken pipe at sun.nio.ch.FileDispatcherImpl.write0(Native Method) at sun.nio.ch.SocketDispatcher.write(SocketDispatcher.java:47) at sun.nio.ch.IOUtil.writeFromNativeBuffer(IOUtil.java:93) at sun.nio.ch.IOUtil.write(IOUtil.java:65) at sun.nio.ch.SocketChannelImpl.write(SocketChannelImpl.java:471) at org.apache.kafka.common.network.SslTransportLayer.flush(SslTransportLayer.java:195) at org.apache.kafka.common.network.SslTransportLayer.close(SslTransportLayer.java:163) at org.apache.kafka.common.utils.Utils.closeAll(Utils.java:690) at org.apache.kafka.common.network.KafkaChannel.close(KafkaChannel.java:47) at org.apache.kafka.common.network.Selector.close(Selector.java:487) at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:368) at org.apache.kafka.common.network.Selector.poll(Selector.java:291) at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:260) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:232) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:180) at kafka.admin.AdminClient.kafka$admin$AdminClient$send(AdminClient.scala:49) at kafka.admin.AdminClient$anonfun$sendAnyNode$1.apply(AdminClient.scala:61) at kafka.admin.AdminClient$anonfun$sendAnyNode$1.apply(AdminClient.scala:58) at scala.collection.immutable.List.foreach(List.scala:318) at kafka.admin.AdminClient.sendAnyNode(AdminClient.scala:58) at kafka.admin.AdminClient.findCoordinator(AdminClient.scala:72) at kafka.admin.AdminClient.describeGroup(AdminClient.scala:125) at kafka.admin.AdminClient.describeConsumerGroup(AdminClient.scala:147) at kafka.admin.ConsumerGroupCommand$KafkaConsumerGroupService.describeGroup(ConsumerGroupCommand.scala:322) at kafka.admin.ConsumerGroupCommand$ConsumerGroupService$class.describe(ConsumerGroupCommand.scala:99) at kafka.admin.ConsumerGroupCommand$KafkaConsumerGroupService.describe(ConsumerGroupCommand.scala:310) at kafka.admin.ConsumerGroupCommand$.main(ConsumerGroupCommand.scala:78) at kafka.admin.ConsumerGroupCommand.main(ConsumerGroupCommand.scala) Error while executing consumer group command Request GROUP_COORDINATOR failed on brokers List(lxapp-cd-hms01:6667 (id: -1 rack: null)) java.lang.RuntimeException: Request GROUP_COORDINATOR failed on brokers List(lxapp-cd-hms01:6667 (id: -1 rack: null)) at kafka.admin.AdminClient.sendAnyNode(AdminClient.scala:67) at kafka.admin.AdminClient.findCoordinator(AdminClient.scala:72) at kafka.admin.AdminClient.describeGroup(AdminClient.scala:125) at kafka.admin.AdminClient.describeConsumerGroup(AdminClient.scala:147) at kafka.admin.ConsumerGroupCommand$KafkaConsumerGroupService.describeGroup(ConsumerGroupCommand.scala:322) at kafka.admin.ConsumerGroupCommand$ConsumerGroupService$class.describe(ConsumerGroupCommand.scala:99) at kafka.admin.ConsumerGroupCommand$KafkaConsumerGroupService.describe(ConsumerGroupCommand.scala:310) at kafka.admin.ConsumerGroupCommand$.main(ConsumerGroupCommand.scala:78) at kafka.admin.ConsumerGroupCommand.main(ConsumerGroupCommand.scala) [2018-10-09 16:31:39,593] WARN TGT renewal thread has been interrupted and will exit. (org.apache.kafka.common.security.kerberos.KerberosLogin)