schumacr Software, Support, and Training for Apache Cassandra en-US Sat, 25 May 2013 15:20:54 +0000 http://bbpress.org/?v=1.0.3 q http://www.datastax.com/support-forums/search.php http://www.datastax.com/support-forums/topic/pig-unable-to-connect-to-cassandra-that-requires-authentication#post-8314 Mon, 07 Jan 2013 16:48:41 +0000 schumacr 8314@http://www.datastax.com/support-forums/ <p>Typically we allow for a 3-4 month time lag between the time a new C* release occurs and when it is integrated into DSE. This allows the new release to bake in the community plus go through our certification program that ensures it's ready for a production setting. For 1.2, I would look for integration in DSE sometime late Q1 or early Q2. </p> http://www.datastax.com/support-forums/topic/pig-unable-to-connect-to-cassandra-that-requires-authentication#post-8306 Mon, 07 Jan 2013 00:39:52 +0000 cko 8306@http://www.datastax.com/support-forums/ <p>In <a href="https://issues.apache.org/jira/browse/CASSANDRA-3042" rel="nofollow">https://issues.apache.org/jira/browse/CASSANDRA-3042</a>, authentication support has already been added to the Pig Load funciton CassandraStorage in Cassandra 1.2.0.</p> <p>Currently DSE 2.2.1 includes Cassandra 1.1.6. Is there a schedule when DSE will include Cassandra 1.2.0?</p> <p>Is there any plan to add Pig Cassandra authentication support to DSE when it includes Cassandra 1.2.0? </p> http://www.datastax.com/support-forums/topic/pig-unable-to-connect-to-cassandra-that-requires-authentication#post-8167 Thu, 27 Dec 2012 21:57:51 +0000 Sven 8167@http://www.datastax.com/support-forums/ <p>SimpleAuthenticator and SimpleAuthority are not currently supported by the DSE components. We are investigating the possibility of adding support for enhanced security in a future release of DSE. </p> http://www.datastax.com/support-forums/topic/pig-unable-to-connect-to-cassandra-that-requires-authentication#post-8152 Thu, 27 Dec 2012 06:35:26 +0000 cko 8152@http://www.datastax.com/support-forums/ <p>Hi,</p> <p>I am trying Cassandra authentication using the sample SimpleAuthenticator and SimpleAuthority classes and also trying securing the Cassandra JMX port. Ops Center can successfully connect to and monitor a Cassandra cluster with the authentication enabled. </p> <p>However there are problems running Pig against a Cassandra cluster with authentication enabled. </p> <p>Looking at the Pig stack trace, we found that the SimpleAuthenticator was throwing an exception during initialisation, so we added the required JVM -D system properties to both scripts $DSE_HOME/bin/dsetool and $DSE_HOME/resources/pig/bin/pig.</p> <p>JVM_OPTS="$JVM_OPTS -Dpasswd.properties=$CASSANDRA_HOME/conf/passwd.properties"<br /> JVM_OPTS="$JVM_OPTS -Daccess.properties=$CASSANDRA_HOME/conf/access.properties"<br /> JVM_OPTS="$JVM_OPTS -Dpasswd.mode=MD5"</p> <p>That takes us further, but then it appears that the CFS custom storage handler received an exception from Cassandra when it tries to connect to the Cassandra database without supplying credentials.</p> <p>Error before Pig is launched<br /> ----------------------------<br /> ERROR 2999: Unexpected internal error. Failed to create DataStorage</p> <p>java.lang.RuntimeException: Failed to create DataStorage<br /> at org.apache.pig.backend.hadoop.datastorage.HDataStorage.init(HDataStorage.java:75)<br /> at org.apache.pig.backend.hadoop.datastorage.HDataStorage.&lt;init&gt;(HDataStorage.java:58)<br /> at org.apache.pig.backend.hadoop.executionengine.HExecutionEngine.init(HExecutionEngine.java:206)<br /> at org.apache.pig.backend.hadoop.executionengine.HExecutionEngine.init(HExecutionEngine.java:119)<br /> at org.apache.pig.impl.PigContext.connect(PigContext.java:185)<br /> at org.apache.pig.PigServer.&lt;init&gt;(PigServer.java:244)<br /> at org.apache.pig.PigServer.&lt;init&gt;(PigServer.java:229)<br /> at org.apache.pig.tools.grunt.Grunt.&lt;init&gt;(Grunt.java:47)<br /> at org.apache.pig.Main.run(Main.java:492)<br /> at org.apache.pig.Main.main(Main.java:111)<br /> Caused by: java.io.IOException: InvalidRequestException(why:You have not logged in)<br /> at com.datastax.bdp.util.CassandraProxyClient.initialize(CassandraProxyClient.java:227)<br /> at com.datastax.bdp.util.CassandraProxyClient.&lt;init&gt;(CassandraProxyClient.java:180)<br /> at com.datastax.bdp.util.CassandraProxyClient.newProxyConnection(CassandraProxyClient.java:119)<br /> at com.datastax.bdp.hadoop.cfs.CassandraFileSystemThriftStore.initialize(CassandraFileSystemThriftStore.java:195)<br /> at com.datastax.bdp.hadoop.cfs.CassandraFileSystem.initialize(CassandraFileSystem.java:67)<br /> at org.apache.hadoop.fs.FileSystem.createFileSystem(FileSystem.java:1386)<br /> at org.apache.hadoop.fs.FileSystem.access$200(FileSystem.java:66)<br /> at org.apache.hadoop.fs.FileSystem$Cache.get(FileSystem.java:1404)<br /> at org.apache.hadoop.fs.FileSystem.get(FileSystem.java:254)<br /> at org.apache.hadoop.fs.FileSystem.get(FileSystem.java:123)<br /> at org.apache.pig.backend.hadoop.datastorage.HDataStorage.init(HDataStorage.java:72)<br /> ... 9 more<br /> Caused by: InvalidRequestException(why:You have not logged in)<br /> at org.apache.cassandra.thrift.Cassandra$describe_keyspaces_result.read(Cassandra.java:22379)<br /> at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:78)<br /> at org.apache.cassandra.thrift.Cassandra$Client.recv_describe_keyspaces(Cassandra.java:1004)<br /> at org.apache.cassandra.thrift.Cassandra$Client.describe_keyspaces(Cassandra.java:992)<br /> at com.datastax.bdp.util.CassandraProxyClient.initialize(CassandraProxyClient.java:213)<br /> ... 19 more</p> <p>I could not find anything in Datastax documentation on how to supply credentials in Pig to connect to Cassandra. Does the current Cassandra storage handler support connecting to a secured Cassandra database? We are using DSE 2.2.1.</p> <p>Thanks in advance.</p> <p>Chin </p>