AnsweredAssumed Answered

Using Flume and HBASE Sink out get error

Question asked by rmeier on Jan 29, 2016
Latest reply on Feb 2, 2016 by pppsunil
Hi,

i try to use flume to transfer some data to hbase in our cluster. But when I start flume I get the following error:

[ERROR - org.apache.zookeeper.client.ZooKeeperSaslClient.createSaslClient(ZooKeeperSaslClient.java:295)] Exception while trying to create SASL client
java.security.PrivilegedActionException: javax.security.sasl.SaslException: Failure to initialize security context [Caused by GSSException: Invalid name provided (Mechanism level: KrbException: Cannot locate default realm)]
    at java.security.AccessController.doPrivileged(Native Method)
    at javax.security.auth.Subject.doAs(Subject.java:415)
    at org.apache.zookeeper.client.ZooKeeperSaslClient.createSaslClient(ZooKeeperSaslClient.java:283)
    at org.apache.zookeeper.client.ZooKeeperSaslClient.<init>(ZooKeeperSaslClient.java:131)
    at org.apache.zookeeper.ClientCnxn$SendThread.startConnect(ClientCnxn.java:949)
    at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1003)

-----
My flume config for hbase is the following:
agent1.sources = spool
agent1.sinks = hbase
agent1.channels = memory2

agent1.sources.spool.type = spooldir
agent1.sources.spool.spoolDir =/tmp/test2/
agent1.sources.spool.fileHeader = true
agent1.sources.spool.deserializer=com.sptech.flume.deserializer.TikaDeserializerBuilder

agent1.sinks.hbase.type=org.apache.flume.sink.hbase.AsyncHBaseSink
agent1.sinks.hbase.table=binary_tika
agent1.sinks.hbase.columnFamily=data
agent1.sinks.hbase.incrementColumn=file

agent1.channels.memory2.type = memory
agent1.channels.memory2.capacity = 1000
agent1.channels.memory2.transactionCapacity = 100

agent1.sources.spool.channels = memory2
agent1.sinks.hbase.channel = memory2

Through the fact that I'm new to mapr I have no clue what the error means. Could somebody help me to point me in the right direction?

Thanks
Ralf

Outcomes