AnsweredAssumed Answered

CASSANDRA -> PDI -> PDR

Question asked by Jarek Gajos on Jan 17, 2018

Hi.

 

I've been trying to connect cassandra as a data source in Pentaho report designer.  We've tried it on 3 different PC but as for now without any success. Looking for some advice what I'm doing wrong here.

 

I've downloaded prd-ce-8.0.0.0-28 and also pdi.

Trying to follow guides:

How To Create a Report with Cassandra using Pentaho Reporting and Kettle - YouTube

How To Read Data From Cassandra - Pentaho Big Data - Pentaho Wiki

Using

System : Windows 7 x64

Java: jdk 1.8 _162

 

In pdi - I've created transformate with cassandra input (I'm using cassandra version 3.2.1). When pressing preview(in pdi) - it shows nicely data form database.

 

Then I try to use pdi as a source dataset in pdr and press Preview there  then I get:

errorPdr.PNG

 

Trying to solve it somehow I've started to dig in pdr logs.

In them I've found something like this:

 

 

2018/01/17 13:02:26 - RepositoriesMeta - Reading repositories XML file: C:\Users\user\.kettle\repositories.xml

2018/01/17 13:02:26 - CassandraInput - Dispatching started for transformation [CassandraInput]

java.lang.SecurityException: Prohibited package name: java.util.concurrent

        at java.lang.ClassLoader.preDefineClass(ClassLoader.java:662)

        at java.lang.ClassLoader.defineClass(ClassLoader.java:761)

        at java.security.SecureClassLoader.defineClass(SecureClassLoader.java:142)

        at java.net.URLClassLoader.defineClass(URLClassLoader.java:467)

        at java.net.URLClassLoader.access$100(URLClassLoader.java:73)

        at java.net.URLClassLoader$1.run(URLClassLoader.java:368)

        at java.net.URLClassLoader$1.run(URLClassLoader.java:362)

        at java.security.AccessController.doPrivileged(Native Method)

        at java.net.URLClassLoader.findClass(URLClassLoader.java:361)

        at org.pentaho.di.core.plugins.KettleURLClassLoader.loadClassFromThisLoader(KettleURLClassLoader.java:78)

        at org.pentaho.di.core.plugins.KettleURLClassLoader.loadClass(KettleURLClassLoader.java:101)

        at java.lang.ClassLoader.loadClass(ClassLoader.java:357)

        at com.datastax.driver.core.policies.DCAwareRoundRobinPolicy.<init>(DCAwareRoundRobinPolicy.java:62)

        at com.datastax.driver.core.policies.DCAwareRoundRobinPolicy.<init>(DCAwareRoundRobinPolicy.java:47)

        at com.datastax.driver.core.policies.DCAwareRoundRobinPolicy$Builder.build(DCAwareRoundRobinPolicy.java:363)

        at com.datastax.driver.core.policies.Policies.defaultLoadBalancingPolicy(Policies.java:76)

        at com.datastax.driver.core.policies.Policies$Builder.build(Policies.java:282)

        at com.datastax.driver.core.Cluster$Builder.getConfiguration(Cluster.java:1317)

        at com.datastax.driver.core.Cluster.<init>(Cluster.java:113)

        at com.datastax.driver.core.Cluster.buildFrom(Cluster.java:178)

        at com.datastax.driver.core.Cluster$Builder.build(Cluster.java:1335)

        at org.pentaho.cassandra.driverimpl.DriverConnection.getCluster(DriverConnection.java:150)

        at org.pentaho.cassandra.driverimpl.DriverConnection.getKeyspace(DriverConnection.java:162)

        at org.pentaho.di.trans.steps.cassandrainput.CassandraInputMeta.getFields(CassandraInputMeta.java:763)

        at org.pentaho.di.trans.TransMeta.compatibleGetStepFields(TransMeta.java:2017)

        at org.pentaho.di.trans.TransMeta.getThisStepFields(TransMeta.java:2003)

        at org.pentaho.di.trans.TransMeta.getStepFields(TransMeta.java:1834)

        at org.pentaho.di.trans.TransMeta.getStepFields(TransMeta.java:1734)

        at org.pentaho.di.trans.TransMeta.getStepFields(TransMeta.java:1696)

        at org.pentaho.di.trans.TransMeta.getStepFields(TransMeta.java:1680)

        at org.pentaho.reporting.engine.classic.extensions.datasources.kettle.AbstractKettleTransformationProducer.performQueryOnTransformation(AbstractKettleTransformationProducer.java:254)

        at org.pentaho.reporting.engine.classic.extensions.datasources.kettle.AbstractKettleTransformationProducer.performQuery(AbstractKettleTransformationProducer.java:233)

        at org.pentaho.reporting.engine.classic.extensions.datasources.kettle.KettleDataFactory.queryData(KettleDataFactory.java:96)

        at org.pentaho.reporting.ui.datasources.kettle.KettleDataSourceDialog$KettlePreviewWorker.run(KettleDataSourceDialog.java:485)

        at java.lang.Thread.run(Thread.java:748)

2018/01/17 13:02:26 - org.pentaho.di.trans.steps.cassandrainput.CassandraInputMeta@2faaabd7 - ERROR (version 8.0.0.0-28, build 8.0.0.0-28 from 2017-11-05 07.27.50 by buildguy) : Prohibited package name: java.util.concurrent

2018-01-17 13:02:26,664 [2396387]  ERROR - org.pentaho.reporting.engine.classic.extensions.datasources.kettle.KettleToCommonsLoggingEventListener - org.pentaho.di.trans.steps.cassandrainput.CassandraInputMeta@2faaabd7 - Prohibited package name: java.util.concurrent

2018/01/17 13:02:26 - org.pentaho.di.trans.steps.cassandrainput.CassandraInputMeta@2faaabd7 - ERROR (version 8.0.0.0-28, build 8.0.0.0-28 from 2017-11-05 07.27.50 by buildguy) : java.lang.SecurityException: Prohibited package name: java.util.concurrent

2018/01/17 13:02:26 - org.pentaho.di.trans.steps.cassandrainput.CassandraInputMeta@2faaabd7 -   at java.lang.ClassLoader.preDefineClass(ClassLoader.java:662)

2018/01/17 13:02:26 - org.pentaho.di.trans.steps.cassandrainput.CassandraInputMeta@2faaabd7 -   at java.lang.ClassLoader.defineClass(ClassLoader.java:761)

2018/01/17 13:02:26 - org.pentaho.di.trans.steps.cassandrainput.CassandraInputMeta@2faaabd7 -   at java.security.SecureClassLoader.defineClass(SecureClassLoader.java:142)

2018/01/17 13:02:26 - org.pentaho.di.trans.steps.cassandrainput.CassandraInputMeta@2faaabd7 -   at java.net.URLClassLoader.defineClass(URLClassLoader.java:467)

2018/01/17 13:02:26 - org.pentaho.di.trans.steps.cassandrainput.CassandraInputMeta@2faaabd7 -   at java.net.URLClassLoader.access$100(URLClassLoader.java:73)

2018/01/17 13:02:26 - org.pentaho.di.trans.steps.cassandrainput.CassandraInputMeta@2faaabd7 -   at java.net.URLClassLoader$1.run(URLClassLoader.java:368)

2018/01/17 13:02:26 - org.pentaho.di.trans.steps.cassandrainput.CassandraInputMeta@2faaabd7 -   at java.net.URLClassLoader$1.run(URLClassLoader.java:362)

2018/01/17 13:02:26 - org.pentaho.di.trans.steps.cassandrainput.CassandraInputMeta@2faaabd7 -   at java.security.AccessController.doPrivileged(Native Method)

2018/01/17 13:02:26 - org.pentaho.di.trans.steps.cassandrainput.CassandraInputMeta@2faaabd7 -   at java.net.URLClassLoader.findClass(URLClassLoader.java:361)

2018/01/17 13:02:26 - org.pentaho.di.trans.steps.cassandrainput.CassandraInputMeta@2faaabd7 -   at org.pentaho.di.core.plugins.KettleURLClassLoader.loadClassFromThisLoader(KettleURLClassLoader.java:78)

2018/01/17 13:02:26 - org.pentaho.di.trans.steps.cassandrainput.CassandraInputMeta@2faaabd7 -   at org.pentaho.di.core.plugins.KettleURLClassLoader.loadClass(KettleURLClassLoader.java:101)

2018/01/17 13:02:26 - org.pentaho.di.trans.steps.cassandrainput.CassandraInputMeta@2faaabd7 -   at java.lang.ClassLoader.loadClass(ClassLoader.java:357)

2018/01/17 13:02:26 - org.pentaho.di.trans.steps.cassandrainput.CassandraInputMeta@2faaabd7 -   at com.datastax.driver.core.policies.DCAwareRoundRobinPolicy.<init>(DCAwareRoundRobinPolicy.java:62)

2018/01/17 13:02:26 - org.pentaho.di.trans.steps.cassandrainput.CassandraInputMeta@2faaabd7 -   at com.datastax.driver.core.policies.DCAwareRoundRobinPolicy.<init>(DCAwareRoundRobinPolicy.java:47)

2018/01/17 13:02:26 - org.pentaho.di.trans.steps.cassandrainput.CassandraInputMeta@2faaabd7 -   at com.datastax.driver.core.policies.DCAwareRoundRobinPolicy$Builder.build(DCAwareRoundRobinPolicy.java:363)

2018/01/17 13:02:26 - org.pentaho.di.trans.steps.cassandrainput.CassandraInputMeta@2faaabd7 -   at com.datastax.driver.core.policies.Policies.defaultLoadBalancingPolicy(Policies.java:76)

2018/01/17 13:02:26 - org.pentaho.di.trans.steps.cassandrainput.CassandraInputMeta@2faaabd7 -   at com.datastax.driver.core.policies.Policies$Builder.build(Policies.java:282)

2018/01/17 13:02:26 - org.pentaho.di.trans.steps.cassandrainput.CassandraInputMeta@2faaabd7 -   at com.datastax.driver.core.Cluster$Builder.getConfiguration(Cluster.java:1317)

2018/01/17 13:02:26 - org.pentaho.di.trans.steps.cassandrainput.CassandraInputMeta@2faaabd7 -   at com.datastax.driver.core.Cluster.<init>(Cluster.java:113)

2018/01/17 13:02:26 - org.pentaho.di.trans.steps.cassandrainput.CassandraInputMeta@2faaabd7 -   at com.datastax.driver.core.Cluster.buildFrom(Cluster.java:178)

2018/01/17 13:02:26 - org.pentaho.di.trans.steps.cassandrainput.CassandraInputMeta@2faaabd7 -   at com.datastax.driver.core.Cluster$Builder.build(Cluster.java:1335)

2018/01/17 13:02:26 - org.pentaho.di.trans.steps.cassandrainput.CassandraInputMeta@2faaabd7 -   at org.pentaho.cassandra.driverimpl.DriverConnection.getCluster(DriverConnection.java:150)

2018/01/17 13:02:26 - org.pentaho.di.trans.steps.cassandrainput.CassandraInputMeta@2faaabd7 -   at org.pentaho.cassandra.driverimpl.DriverConnection.getKeyspace(DriverConnection.java:162)

2018/01/17 13:02:26 - org.pentaho.di.trans.steps.cassandrainput.CassandraInputMeta@2faaabd7 -   at org.pentaho.di.trans.steps.cassandrainput.CassandraInputMeta.getFields(CassandraInputMeta.java:763)

2018/01/17 13:02:26 - org.pentaho.di.trans.steps.cassandrainput.CassandraInputMeta@2faaabd7 -   at org.pentaho.di.trans.TransMeta.compatibleGetStepFields(TransMeta.java:2017)

2018/01/17 13:02:26 - org.pentaho.di.trans.steps.cassandrainput.CassandraInputMeta@2faaabd7 -   at org.pentaho.di.trans.TransMeta.getThisStepFields(TransMeta.java:2003)

2018/01/17 13:02:26 - org.pentaho.di.trans.steps.cassandrainput.CassandraInputMeta@2faaabd7 -   at org.pentaho.di.trans.TransMeta.getStepFields(TransMeta.java:1834)

2018/01/17 13:02:26 - org.pentaho.di.trans.steps.cassandrainput.CassandraInputMeta@2faaabd7 -   at org.pentaho.di.trans.TransMeta.getStepFields(TransMeta.java:1734)

2018/01/17 13:02:26 - org.pentaho.di.trans.steps.cassandrainput.CassandraInputMeta@2faaabd7 -   at org.pentaho.di.trans.TransMeta.getStepFields(TransMeta.java:1696)

2018/01/17 13:02:26 - org.pentaho.di.trans.steps.cassandrainput.CassandraInputMeta@2faaabd7 -   at org.pentaho.di.trans.TransMeta.getStepFields(TransMeta.java:1680)

2018/01/17 13:02:26 - org.pentaho.di.trans.steps.cassandrainput.CassandraInputMeta@2faaabd7 -   at org.pentaho.reporting.engine.classic.extensions.datasources.kettle.AbstractKettleTransformationProducer.performQueryOnTransformation(AbstractKettleTransformationProducer.java:254)

2018/01/17 13:02:26 - org.pentaho.di.trans.steps.cassandrainput.CassandraInputMeta@2faaabd7 -   at org.pentaho.reporting.engine.classic.extensions.datasources.kettle.AbstractKettleTransformationProducer.performQuery(AbstractKettleTransformationProducer.java:233)

2018/01/17 13:02:26 - org.pentaho.di.trans.steps.cassandrainput.CassandraInputMeta@2faaabd7 -   at org.pentaho.reporting.engine.classic.extensions.datasources.kettle.KettleDataFactory.queryData(KettleDataFactory.java:96)

2018/01/17 13:02:26 - org.pentaho.di.trans.steps.cassandrainput.CassandraInputMeta@2faaabd7 -   at org.pentaho.reporting.ui.datasources.kettle.KettleDataSourceDialog$KettlePreviewWorker.run(KettleDataSourceDialog.java:485)

2018/01/17 13:02:26 - org.pentaho.di.trans.steps.cassandrainput.CassandraInputMeta@2faaabd7 -   at java.lang.Thread.run(Thread.java:748)

2018-01-17 13:02:26,664 [2396387]  ERROR - org.pentaho.reporting.engine.classic.extensions.datasources.kettle.KettleToCommonsLoggingEventListener - org.pentaho.di.trans.steps.cassandrainput.CassandraInputMeta@2faaabd7 - java.lang.SecurityException: Prohibited package name: java.util.concurrent

        at java.lang.ClassLoader.preDefineClass(ClassLoader.java:662)

        at java.lang.ClassLoader.defineClass(ClassLoader.java:761)

        at java.security.SecureClassLoader.defineClass(SecureClassLoader.java:142)

        at java.net.URLClassLoader.defineClass(URLClassLoader.java:467)

        at java.net.URLClassLoader.access$100(URLClassLoader.java:73)

        at java.net.URLClassLoader$1.run(URLClassLoader.java:368)

        at java.net.URLClassLoader$1.run(URLClassLoader.java:362)

        at java.security.AccessController.doPrivileged(Native Method)

        at java.net.URLClassLoader.findClass(URLClassLoader.java:361)

        at org.pentaho.di.core.plugins.KettleURLClassLoader.loadClassFromThisLoader(KettleURLClassLoader.java:78)

        at org.pentaho.di.core.plugins.KettleURLClassLoader.loadClass(KettleURLClassLoader.java:101)

        at java.lang.ClassLoader.loadClass(ClassLoader.java:357)

        at com.datastax.driver.core.policies.DCAwareRoundRobinPolicy.<init>(DCAwareRoundRobinPolicy.java:62)

        at com.datastax.driver.core.policies.DCAwareRoundRobinPolicy.<init>(DCAwareRoundRobinPolicy.java:47)

        at com.datastax.driver.core.policies.DCAwareRoundRobinPolicy$Builder.build(DCAwareRoundRobinPolicy.java:363)

        at com.datastax.driver.core.policies.Policies.defaultLoadBalancingPolicy(Policies.java:76)

        at com.datastax.driver.core.policies.Policies$Builder.build(Policies.java:282)

        at com.datastax.driver.core.Cluster$Builder.getConfiguration(Cluster.java:1317)

        at com.datastax.driver.core.Cluster.<init>(Cluster.java:113)

        at com.datastax.driver.core.Cluster.buildFrom(Cluster.java:178)

        at com.datastax.driver.core.Cluster$Builder.build(Cluster.java:1335)

        at org.pentaho.cassandra.driverimpl.DriverConnection.getCluster(DriverConnection.java:150)

        at org.pentaho.cassandra.driverimpl.DriverConnection.getKeyspace(DriverConnection.java:162)

        at org.pentaho.di.trans.steps.cassandrainput.CassandraInputMeta.getFields(CassandraInputMeta.java:763)

        at org.pentaho.di.trans.TransMeta.compatibleGetStepFields(TransMeta.java:2017)

        at org.pentaho.di.trans.TransMeta.getThisStepFields(TransMeta.java:2003)

        at org.pentaho.di.trans.TransMeta.getStepFields(TransMeta.java:1834)

        at org.pentaho.di.trans.TransMeta.getStepFields(TransMeta.java:1734)

        at org.pentaho.di.trans.TransMeta.getStepFields(TransMeta.java:1696)

        at org.pentaho.di.trans.TransMeta.getStepFields(TransMeta.java:1680)

        at org.pentaho.reporting.engine.classic.extensions.datasources.kettle.AbstractKettleTransformationProducer.performQueryOnTransformation(AbstractKettleTransformationProducer.java:254)

        at org.pentaho.reporting.engine.classic.extensions.datasources.kettle.AbstractKettleTransformationProducer.performQuery(AbstractKettleTransformationProducer.java:233)

        at org.pentaho.reporting.engine.classic.extensions.datasources.kettle.KettleDataFactory.queryData(KettleDataFactory.java:96)

        at org.pentaho.reporting.ui.datasources.kettle.KettleDataSourceDialog$KettlePreviewWorker.run(KettleDataSourceDialog.java:485)

        at java.lang.Thread.run(Thread.java:748)

 

2018/01/17 13:02:26 - Cassandra Input.0 - Connecting to Cassandra node at X.X.X.X : 9042 using keyspace urs ...

2018/01/17 13:02:26 - Cassandra Input.0 - Using connection options: cqlVersion=3.0.1

2018/01/17 13:02:26 - Cassandra Input.0 - Closing connection ...

org.pentaho.di.core.exception.KettleException:

Prohibited package name: java.util.concurrent

Prohibited package name: java.util.concurrent

 

        at org.pentaho.di.trans.steps.cassandrainput.CassandraInput.processRow(CassandraInput.java:173)

        at org.pentaho.di.trans.step.RunThread.run(RunThread.java:62)

        at java.lang.Thread.run(Thread.java:748)

Caused by: java.lang.SecurityException: Prohibited package name: java.util.concurrent

        at java.lang.ClassLoader.preDefineClass(ClassLoader.java:662)

        at java.lang.ClassLoader.defineClass(ClassLoader.java:761)

        at java.security.SecureClassLoader.defineClass(SecureClassLoader.java:142)

        at java.net.URLClassLoader.defineClass(URLClassLoader.java:467)

        at java.net.URLClassLoader.access$100(URLClassLoader.java:73)

        at java.net.URLClassLoader$1.run(URLClassLoader.java:368)

        at java.net.URLClassLoader$1.run(URLClassLoader.java:362)

        at java.security.AccessController.doPrivileged(Native Method)

        at java.net.URLClassLoader.findClass(URLClassLoader.java:361)

        at org.pentaho.di.core.plugins.KettleURLClassLoader.loadClassFromThisLoader(KettleURLClassLoader.java:78)

        at org.pentaho.di.core.plugins.KettleURLClassLoader.loadClass(KettleURLClassLoader.java:101)

        at java.lang.ClassLoader.loadClass(ClassLoader.java:357)

        at com.datastax.driver.core.policies.DCAwareRoundRobinPolicy.<init>(DCAwareRoundRobinPolicy.java:62)

        at com.datastax.driver.core.policies.DCAwareRoundRobinPolicy.<init>(DCAwareRoundRobinPolicy.java:47)

        at com.datastax.driver.core.policies.DCAwareRoundRobinPolicy$Builder.build(DCAwareRoundRobinPolicy.java:363)

        at com.datastax.driver.core.policies.Policies.defaultLoadBalancingPolicy(Policies.java:76)

        at com.datastax.driver.core.policies.Policies$Builder.build(Policies.java:282)

        at com.datastax.driver.core.Cluster$Builder.getConfiguration(Cluster.java:1317)

        at com.datastax.driver.core.Cluster.<init>(Cluster.java:113)

        at com.datastax.driver.core.Cluster.buildFrom(Cluster.java:178)

        at com.datastax.driver.core.Cluster$Builder.build(Cluster.java:1335)

        at org.pentaho.cassandra.driverimpl.DriverConnection.getCluster(DriverConnection.java:150)

        at org.pentaho.cassandra.driverimpl.DriverConnection.getKeyspace(DriverConnection.java:162)

        at org.pentaho.di.trans.steps.cassandrainput.CassandraInput.processRow(CassandraInput.java:170)

        ... 2 more

2018/01/17 13:02:26 - Cassandra Input.0 - ERROR (version 8.0.0.0-28, build 8.0.0.0-28 from 2017-11-05 07.27.50 by buildguy) : Unexpected error

2018-01-17 13:02:26,667 [2396390]  ERROR - org.pentaho.reporting.engine.classic.extensions.datasources.kettle.KettleToCommonsLoggingEventListener - Cassandra Input - Unexpected error

2018/01/17 13:02:26 - Cassandra Input.0 - ERROR (version 8.0.0.0-28, build 8.0.0.0-28 from 2017-11-05 07.27.50 by buildguy) : org.pentaho.di.core.exception.KettleException:

2018/01/17 13:02:26 - Cassandra Input.0 - Prohibited package name: java.util.concurrent

2018/01/17 13:02:26 - Cassandra Input.0 - Prohibited package name: java.util.concurrent

2018/01/17 13:02:26 - Cassandra Input.0 -

2018/01/17 13:02:26 - Cassandra Input.0 -       at org.pentaho.di.trans.steps.cassandrainput.CassandraInput.processRow(CassandraInput.java:173)

2018/01/17 13:02:26 - Cassandra Input.0 -       at org.pentaho.di.trans.step.RunThread.run(RunThread.java:62)

2018/01/17 13:02:26 - Cassandra Input.0 -       at java.lang.Thread.run(Thread.java:748)

2018/01/17 13:02:26 - Cassandra Input.0 - Caused by: java.lang.SecurityException: Prohibited package name: java.util.concurrent

2018/01/17 13:02:26 - Cassandra Input.0 -       at java.lang.ClassLoader.preDefineClass(ClassLoader.java:662)

2018/01/17 13:02:26 - Cassandra Input.0 -       at java.lang.ClassLoader.defineClass(ClassLoader.java:761)

2018/01/17 13:02:26 - Cassandra Input.0 -       at java.security.SecureClassLoader.defineClass(SecureClassLoader.java:142)

2018/01/17 13:02:26 - Cassandra Input.0 -       at java.net.URLClassLoader.defineClass(URLClassLoader.java:467)

2018/01/17 13:02:26 - Cassandra Input.0 -       at java.net.URLClassLoader.access$100(URLClassLoader.java:73)

2018/01/17 13:02:26 - Cassandra Input.0 -       at java.net.URLClassLoader$1.run(URLClassLoader.java:368)

2018/01/17 13:02:26 - Cassandra Input.0 -       at java.net.URLClassLoader$1.run(URLClassLoader.java:362)

2018/01/17 13:02:26 - Cassandra Input.0 -       at java.security.AccessController.doPrivileged(Native Method)

2018/01/17 13:02:26 - Cassandra Input.0 -       at java.net.URLClassLoader.findClass(URLClassLoader.java:361)

2018/01/17 13:02:26 - Cassandra Input.0 -       at org.pentaho.di.core.plugins.KettleURLClassLoader.loadClassFromThisLoader(KettleURLClassLoader.java:78)

2018/01/17 13:02:26 - Cassandra Input.0 -       at org.pentaho.di.core.plugins.KettleURLClassLoader.loadClass(KettleURLClassLoader.java:101)

2018/01/17 13:02:26 - Cassandra Input.0 -       at java.lang.ClassLoader.loadClass(ClassLoader.java:357)

2018/01/17 13:02:26 - Cassandra Input.0 -       at com.datastax.driver.core.policies.DCAwareRoundRobinPolicy.<init>(DCAwareRoundRobinPolicy.java:62)

2018/01/17 13:02:26 - Cassandra Input.0 -       at com.datastax.driver.core.policies.DCAwareRoundRobinPolicy.<init>(DCAwareRoundRobinPolicy.java:47)

2018/01/17 13:02:26 - Cassandra Input.0 -       at com.datastax.driver.core.policies.DCAwareRoundRobinPolicy$Builder.build(DCAwareRoundRobinPolicy.java:363)

2018/01/17 13:02:26 - Cassandra Input.0 -       at com.datastax.driver.core.policies.Policies.defaultLoadBalancingPolicy(Policies.java:76)

2018/01/17 13:02:26 - Cassandra Input.0 -       at com.datastax.driver.core.policies.Policies$Builder.build(Policies.java:282)

2018/01/17 13:02:26 - Cassandra Input.0 -       at com.datastax.driver.core.Cluster$Builder.getConfiguration(Cluster.java:1317)

2018/01/17 13:02:26 - Cassandra Input.0 -       at com.datastax.driver.core.Cluster.<init>(Cluster.java:113)

2018/01/17 13:02:26 - Cassandra Input.0 -       at com.datastax.driver.core.Cluster.buildFrom(Cluster.java:178)

2018/01/17 13:02:26 - Cassandra Input.0 -       at com.datastax.driver.core.Cluster$Builder.build(Cluster.java:1335)

2018/01/17 13:02:26 - Cassandra Input.0 -       at org.pentaho.cassandra.driverimpl.DriverConnection.getCluster(DriverConnection.java:150)

2018/01/17 13:02:26 - Cassandra Input.0 -       at org.pentaho.cassandra.driverimpl.DriverConnection.getKeyspace(DriverConnection.java:162)

2018/01/17 13:02:26 - Cassandra Input.0 -       at org.pentaho.di.trans.steps.cassandrainput.CassandraInput.processRow(CassandraInput.java:170)

2018/01/17 13:02:26 - Cassandra Input.0 -       ... 2 more

2018-01-17 13:02:26,668 [2396391]  ERROR - org.pentaho.reporting.engine.classic.extensions.datasources.kettle.KettleToCommonsLoggingEventListener - Cassandra Input - org.pentaho.di.core.exception.KettleException:

Prohibited package name: java.util.concurrent

Prohibited package name: java.util.concurrent

 

        at org.pentaho.di.trans.steps.cassandrainput.CassandraInput.processRow(CassandraInput.java:173)

        at org.pentaho.di.trans.step.RunThread.run(RunThread.java:62)

        at java.lang.Thread.run(Thread.java:748)

Caused by: java.lang.SecurityException: Prohibited package name: java.util.concurrent

        at java.lang.ClassLoader.preDefineClass(ClassLoader.java:662)

        at java.lang.ClassLoader.defineClass(ClassLoader.java:761)

        at java.security.SecureClassLoader.defineClass(SecureClassLoader.java:142)

        at java.net.URLClassLoader.defineClass(URLClassLoader.java:467)

        at java.net.URLClassLoader.access$100(URLClassLoader.java:73)

        at java.net.URLClassLoader$1.run(URLClassLoader.java:368)

        at java.net.URLClassLoader$1.run(URLClassLoader.java:362)

        at java.security.AccessController.doPrivileged(Native Method)

        at java.net.URLClassLoader.findClass(URLClassLoader.java:361)

        at org.pentaho.di.core.plugins.KettleURLClassLoader.loadClassFromThisLoader(KettleURLClassLoader.java:78)

        at org.pentaho.di.core.plugins.KettleURLClassLoader.loadClass(KettleURLClassLoader.java:101)

        at java.lang.ClassLoader.loadClass(ClassLoader.java:357)

        at com.datastax.driver.core.policies.DCAwareRoundRobinPolicy.<init>(DCAwareRoundRobinPolicy.java:62)

        at com.datastax.driver.core.policies.DCAwareRoundRobinPolicy.<init>(DCAwareRoundRobinPolicy.java:47)

        at com.datastax.driver.core.policies.DCAwareRoundRobinPolicy$Builder.build(DCAwareRoundRobinPolicy.java:363)

        at com.datastax.driver.core.policies.Policies.defaultLoadBalancingPolicy(Policies.java:76)

        at com.datastax.driver.core.policies.Policies$Builder.build(Policies.java:282)

        at com.datastax.driver.core.Cluster$Builder.getConfiguration(Cluster.java:1317)

        at com.datastax.driver.core.Cluster.<init>(Cluster.java:113)

        at com.datastax.driver.core.Cluster.buildFrom(Cluster.java:178)

        at com.datastax.driver.core.Cluster$Builder.build(Cluster.java:1335)

        at org.pentaho.cassandra.driverimpl.DriverConnection.getCluster(DriverConnection.java:150)

        at org.pentaho.cassandra.driverimpl.DriverConnection.getKeyspace(DriverConnection.java:162)

        at org.pentaho.di.trans.steps.cassandrainput.CassandraInput.processRow(CassandraInput.java:170)

        ... 2 more

 

2018/01/17 13:02:26 - Cassandra Input.0 - Finished processing (I=0, O=0, R=0, W=0, U=0, E=1)

2018/01/17 13:02:26 - CassandraInput - Transformation detected one or more steps with errors.

2018/01/17 13:02:26 - CassandraInput - ERROR (version 8.0.0.0-28, build 8.0.0.0-28 from 2017-11-05 07.27.50 by buildguy) : Errors detected!

2018-01-17 13:02:26,669 [2396392]  ERROR - org.pentaho.reporting.engine.classic.extensions.datasources.kettle.KettleToCommonsLoggingEventListener - CassandraInput - Errors detected!

2018/01/17 13:02:26 - CassandraInput - ERROR (version 8.0.0.0-28, build 8.0.0.0-28 from 2017-11-05 07.27.50 by buildguy) : Errors detected!

2018-01-17 13:02:26,670 [2396393]  ERROR - org.pentaho.reporting.engine.classic.extensions.datasources.kettle.KettleToCommonsLoggingEventListener - CassandraInput - Errors detected!

2018/01/17 13:02:26 - CassandraInput - Transformation is killing the other steps!

2018-01-17 13:02:26,681 [2396404]  ERROR - org.pentaho.reporting.engine.classic.core.modules.gui.commonswing.ExceptionDialog - ExceptionDialog.ERROR_0001 - UserError

org.pentaho.reporting.engine.classic.core.ReportDataFactoryException: Transformation reported 1 records with errors and stop-on-error is true. Aborting.

        at org.pentaho.reporting.engine.classic.extensions.datasources.kettle.AbstractKettleTransformationProducer.performQueryOnTransformation(AbstractKettleTransformationProducer.java:268)

        at org.pentaho.reporting.engine.classic.extensions.datasources.kettle.AbstractKettleTransformationProducer.performQuery(AbstractKettleTransformationProducer.java:233)

        at org.pentaho.reporting.engine.classic.extensions.datasources.kettle.KettleDataFactory.queryData(KettleDataFactory.java:96)

        at org.pentaho.reporting.ui.datasources.kettle.KettleDataSourceDialog$KettlePreviewWorker.run(KettleDataSourceDialog.java:485)

        at java.lang.Thread.run(Thread.java:748)

 

 

 

Seems there to be some confilct:

 

2018-01-17
13:02:26,668 [2396391]  ERROR - org.pentaho.reporting.engine.classic.extensions.datasources.kettle.KettleToCommonsLoggingEventListener - Cassandra Input - org.pentaho.di.core.exception.KettleException:

Prohibited package name: java.util.concurrent

 

Is there any tutorial showing who to use PDR with cassand

Outcomes