Using Data Integrator 6.0 CE on a Windows 7 machine - trying to connect to a Cassandra 2.1.8 repository. When I attempt to setup a Cassandra Input connection - I get an unexpected error - which I expect is a connection refusal because I would have connection issues using cqlsh command line if I forgot the --ssl flag. I should also add - the certificate is self-signed.

I have tired to add the certificate to a java keystore - but am not sure what else to try to fix this.

Any help appreciated.

Below is the error:

2015/11/24 15:46:52 - org.pentaho.di.trans.steps.cassandrainput.CassandraInputMeta@4e21d50b - ERROR (version 6.0.0.0-353, build 1 from 2015-10-07 13.27.43 by buildguy) : No SELECT in query!
2015/11/24 16:57:39 - C:\******\pdi-ce-6.0.0.0-353\data-integration\transform1.ktr : transform1 - Dispatching started for transformation [C:\*********\pdi-ce-6.0.0.0-353\data-integration\transform1.ktr : transform1]
2015/11/24 16:57:39 - Dev_projects_input.0 - Connecting to Cassandra node at {hostname} : 9042 using keyspace sysetm ...
2015/11/24 16:57:39 - Dev_projects_input.0 - Closing connection ...
2015/11/24 16:57:39 - Dev_projects_input.0 - ERROR (version 6.0.0.0-353, build 1 from 2015-10-07 13.27.43 by buildguy) : Unexpected error
2015/11/24 16:57:39 - Dev_projects_input.0 - ERROR (version 6.0.0.0-353, build 1 from 2015-10-07 13.27.43 by buildguy) : org.pentaho.di.core.exception.KettleException:
2015/11/24 16:57:39 - Dev_projects_input.0 - null
2015/11/24 16:57:39 - Dev_projects_input.0 - at java.lang.Thread.run (null:-1)
2015/11/24 16:57:39 - Dev_projects_input.0 - at org.pentaho.di.trans.step.RunThread.run (RunThread.java:62)
2015/11/24 16:57:39 - Dev_projects_input.0 - at org.pentaho.di.trans.steps.cassandrainput.CassandraInput.processRow (CassandraInput.java:164)
2015/11/24 16:57:39 - Dev_projects_input.0 - at org.pentaho.cassandra.legacy.CassandraConnection.getKeyspace (CassandraConnection.java:303)
2015/11/24 16:57:39 - Dev_projects_input.0 - at org.pentaho.cassandra.legacy.LegacyKeyspace.setKeyspace (LegacyKeyspace.java:100)
2015/11/24 16:57:39 - Dev_projects_input.0 - at org.pentaho.cassandra.legacy.CassandraConnection.setKeyspace (CassandraConnection.java:185)
2015/11/24 16:57:39 - Dev_projects_input.0 - at org.pentaho.cassandra.legacy.CassandraConnection.checkOpen (CassandraConnection.java:162)
2015/11/24 16:57:39 - Dev_projects_input.0 - at org.pentaho.cassandra.legacy.CassandraConnection.openConnection (CassandraConnection.java:274)
2015/11/24 16:57:39 - Dev_projects_input.0 - at org.apache.cassandra.thrift.Cassandra$Client.login (Cassandra.java:560)
2015/11/24 16:57:39 - Dev_projects_input.0 - at org.apache.cassandra.thrift.Cassandra$Client.recv_login (Cassandra.java:573)
2015/11/24 16:57:39 - Dev_projects_input.0 - at org.apache.thrift.TServiceClient.receiveBase (TServiceClient.java:69)
2015/11/24 16:57:39 - Dev_projects_input.0 - at org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin (TBinaryProtocol.java:191)
2015/11/24 16:57:39 - Dev_projects_input.0 - at org.apache.thrift.protocol.TBinaryProtocol.readI32 (TBinaryProtocol.java:284)
2015/11/24 16:57:39 - Dev_projects_input.0 - at org.apache.thrift.protocol.TBinaryProtocol.readAll (TBinaryProtocol.java:362)
2015/11/24 16:57:39 - Dev_projects_input.0 - at org.apache.thrift.transport.TTransport.readAll (TTransport.java:84)
2015/11/24 16:57:39 - Dev_projects_input.0 - at org.apache.thrift.transport.TFramedTransport.read (TFramedTransport.java:101)
2015/11/24 16:57:39 - Dev_projects_input.0 - at org.apache.thrift.transport.TFramedTransport.readFrame (TFramedTransport.java:129)
2015/11/24 16:57:39 - Dev_projects_input.0 - at org.apache.thrift.transport.TTransport.readAll (TTransport.java:84)
2015/11/24 16:57:39 - Dev_projects_input.0 - at org.apache.thrift.transport.TIOStreamTransport.read (TIOStreamTransport.java:132)
2015/11/24 16:57:39 - Dev_projects_input.0 -
2015/11/24 16:57:39 - Dev_projects_input.0 - at org.pentaho.di.trans.steps.cassandrainput.CassandraInput.processRow(CassandraInput.java:167)
2015/11/24 16:57:39 - Dev_projects_input.0 - at org.pentaho.di.trans.step.RunThread.run(RunThread.java:62)
2015/11/24 16:57:39 - Dev_projects_input.0 - at java.lang.Thread.run(Unknown Source)
2015/11/24 16:57:39 - Dev_projects_input.0 - Caused by: org.apache.thrift.transport.TTransportException
2015/11/24 16:57:39 - Dev_projects_input.0 - at org.apache.thrift.transport.TIOStreamTransport.read(TIOStreamTransport.java:132)
2015/11/24 16:57:39 - Dev_projects_input.0 - at org.apache.thrift.transport.TTransport.readAll(TTransport.java:84)
2015/11/24 16:57:39 - Dev_projects_input.0 - at org.apache.thrift.transport.TFramedTransport.readFrame(TFramedTransport.java:129)
2015/11/24 16:57:39 - Dev_projects_input.0 - at org.apache.thrift.transport.TFramedTransport.read(TFramedTransport.java:101)
2015/11/24 16:57:39 - Dev_projects_input.0 - at org.apache.thrift.transport.TTransport.readAll(TTransport.java:84)
2015/11/24 16:57:39 - Dev_projects_input.0 - at org.apache.thrift.protocol.TBinaryProtocol.readAll(TBinaryProtocol.java:362)
2015/11/24 16:57:39 - Dev_projects_input.0 - at org.apache.thrift.protocol.TBinaryProtocol.readI32(TBinaryProtocol.java:284)
2015/11/24 16:57:39 - Dev_projects_input.0 - at org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.java:191)
2015/11/24 16:57:39 - Dev_projects_input.0 - at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:69)
2015/11/24 16:57:39 - Dev_projects_input.0 - at org.apache.cassandra.thrift.Cassandra$Client.recv_login(Cassandra.java:573)
2015/11/24 16:57:39 - Dev_projects_input.0 - at org.apache.cassandra.thrift.Cassandra$Client.login(Cassandra.java:560)
2015/11/24 16:57:39 - Dev_projects_input.0 - at org.pentaho.cassandra.legacy.CassandraConnection.openConnection(CassandraConnection.java:274)
2015/11/24 16:57:39 - Dev_projects_input.0 - at org.pentaho.cassandra.legacy.CassandraConnection.checkOpen(CassandraConnection.java:162)
2015/11/24 16:57:39 - Dev_projects_input.0 - at org.pentaho.cassandra.legacy.CassandraConnection.setKeyspace(CassandraConnection.java:185)
2015/11/24 16:57:39 - Dev_projects_input.0 - at org.pentaho.cassandra.legacy.LegacyKeyspace.setKeyspace(LegacyKeyspace.java:100)
2015/11/24 16:57:39 - Dev_projects_input.0 - at org.pentaho.cassandra.legacy.CassandraConnection.getKeyspace(CassandraConnection.java:303)
2015/11/24 16:57:39 - Dev_projects_input.0 - at org.pentaho.di.trans.steps.cassandrainput.CassandraInput.processRow(CassandraInput.java:164)
2015/11/24 16:57:39 - Dev_projects_input.0 - ... 2 more

The paramaters that I am using for the Cassandra input are the following:

Step Name - dev_project_input
Cassandra Host {same hostname}
Casssandra Port - 9042
Socket timeout - {blank}
transport max length = {blank}
Username - same as that is used in the cqlsh
Password - same as used in the cqlsh
Keyspace - system (can this be used for Keyspaces like "Test" with the quotes?)
CQL - SELECT * FROM PEERS