AnsweredAssumed Answered

CASSANDRA -> PDI -> PDR

Question asked by Jarek Gajos on Jan 17, 2018

Like • Show 0 Likes0
Comment • 0

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:

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

No one else has this question

Jive

Hitachi Vantara Community

CASSANDRA -> PDI -> PDR

Outcomes

Related Content

Recommended Content