cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Henning Kropp (JIRA)" <>
Subject [jira] [Created] (CASSANDRA-7083) Authentication Support for CqlRecordWriter
Date Thu, 24 Apr 2014 14:09:14 GMT
Henning Kropp created CASSANDRA-7083:

             Summary: Authentication Support for CqlRecordWriter
                 Key: CASSANDRA-7083
             Project: Cassandra
          Issue Type: Bug
          Components: Hadoop
            Reporter: Henning Kropp
         Attachments: auth_cql.patch

The {{CqlRecordWriter}} seems not to support authentication. When the keyspace in Cassandra
is to set to use authentication our Pig job fails with, when credentials are provided using
the URI ('cql://username:password...):
java.lang.RuntimeException: InvalidRequestException(why:You have not logged in)
	at org.apache.cassandra.hadoop.cql3.CqlRecordWriter.(
	at org.apache.cassandra.hadoop.cql3.CqlRecordWriter.(
	at org.apache.cassandra.hadoop.cql3.CqlOutputFormat.getRecordWriter(
	at org.apache.cassandra.hadoop.cql3.CqlOutputFormat.getRecordWriter(
	at org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigOutputFormat.getRecordWriter(
	at org.apache.hadoop.mapred.ReduceTask.runNewReducer(
	at org.apache.hadoop.mapred.Child.main(
Caused by: InvalidRequestException(why:You have not logged in)
	at org.apache.cassandra.thrift.Cassandra$
	at org.apache.thrift.TServiceClient.receiveBase(
	at org.apache.cassandra.thrift.Cassandra$Client.recv_execute_cql3_query(
	at org.apache.cassandra.thrift.Cassandra$Client.execute_cql3_query(
	at org.apache.cassandra.hadoop.cql3.CqlRecordWriter.retrievePartitionKeyValidator(
	at org.apache.cassandra.hadoop.cql3.CqlRecordWriter.(
	... 7 more

If not supplied in the URI but as a {{JobConf}} the exception:
Output Location Validation Failed for: 'cql://...' More info to follow:
InvalidRequestException(why:You have not logged in)
        at org.apache.pig.newplan.logical.rules.InputOutputFileValidator$

Which let to the finding, that authentication is correctly supplied for {{CqlStorage}} but
not for the {{CqlRecordWriter}}.

May be it would make sense to put the authentication part into {{ConfigHelper.getClientFromAddressList()}}?
Then in {{CqlStorage} the username and password in the conf would need to be set from the
URI. If so the {{ConfigHelper}} has all the information to authenticate and already returns
the client.

This message was sent by Atlassian JIRA

View raw message