Hi Oleg, we tried and no luck. This is another example where we are seeing
similar issue. Attached txt has the java code as well as the log.
Thanks in advance
Anil
On Wed, Mar 15, 2017 at 10:02 AM, Anil Rai <[email protected]> wrote:
> Thanks Oleg. Makes sense. Will try and keep you posted.
>
> Regards
> Anil
>
>
> On Wed, Mar 15, 2017 at 9:56 AM, Oleg Zhurakousky <
> [email protected]> wrote:
>
>> Anil
>>
>> Thank you for details. That does help a lot.
>>
>> First, I want to make sure that it is clear that this is not a NiFi
>> issue, since the problem is specific to the combination of DBCP and Oracle
>> and the expectations between the two.
>>
>> Seems like Oracle JDBC connection is wrapped in an implementation
>> specific class (DBCP in this case I assume).
>> It is my believe that you need to obtain reference to native Oracle
>> connection to avoid "JMS-112: Connection is invalid".
>> So, I think you need to try to cast your Connection object to DBCPs
>> DelegatingConnection and then do something like this:
>>
>> DelegatingConnection wrappedConn = (DelegatingConnection)con;
>> OracleConnection ocon = null ;
>> if (wrappedConn != null)
>> ocon = (OracleConnection) wrappedConn.getDelegate();
>> . . .
>>
>> Let me know how it goes
>>
>> Cheers
>> Oleg
>>
>> > On Mar 15, 2017, at 9:20 AM, Anil Rai <[email protected]> wrote:
>> >
>> > 2017-03-14 16:50:42,312 ERROR [NiFi logging handler]
>> org.apache.nifi.StdErr
>> > at
>> > java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
>> > 2017-03-14 16:50:42,313 ERROR [NiFi logging handler]
>> org.apache.nifi.StdErr
>> > at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:
>> 308)
>> > 2017-03-14 16:50:42,313 ERROR [NiFi logging handler]
>> org.apache.nifi.StdErr
>> > at
>> > java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFu
>> tureTask.access$301(ScheduledThreadPoolExecutor.java:180)
>> > 2017-03-14 16:50:42,313 ERROR [NiFi logging handler]
>> org.apache.nifi.StdErr
>> > at
>> > java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFu
>> tureTask.run(ScheduledThreadPoolExecutor.java:294)
>> > 2017-03-14 16:50:42,313 ERROR [NiFi logging handler]
>> org.apache.nifi.StdErr
>> > at
>> > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPool
>> Executor.java:1142)
>> > 2017-03-14 16:50:42,313 ERROR [NiFi logging handler]
>> org.apache.nifi.StdErr
>> > at
>> > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoo
>> lExecutor.java:617)
>> > 2017-03-14 16:50:42,313 ERROR [NiFi logging handler]
>> org.apache.nifi.StdErr
>> > at java.lang.Thread.run(Thread.java:745)
>> > 2017-03-14 16:50:43,567 INFO [NiFi logging handler]
>> org.apache.nifi.StdOut
>> > Databse Connection :- jdbc:oracle:thin:@xxxog.yy.com:1521/DB1,
>> > UserName=user, Oracle JDBC driver
>> > 2017-03-14 16:50:43,567 ERROR [NiFi logging handler]
>> org.apache.nifi.StdErr
>> > oracle.AQ.AQException: JMS-112: Connection is invalid
>> > 2017-03-14 16:50:43,567 INFO [NiFi logging handler]
>> org.apache.nifi.StdOut
>> > AQ Driver Class ---> oracle.AQ.AQOracleDriver
>> > 2017-03-14 16:50:43,567 ERROR [NiFi logging handler]
>> org.apache.nifi.StdErr
>> > 2017-03-14 16:50:43,568 INFO [NiFi logging handler]
>> org.apache.nifi.StdOut
>> > Aq Sesssion ---> null
>> > 2017-03-14 16:50:43,568 ERROR [NiFi logging handler]
>> org.apache.nifi.StdErr
>> > 2017-03-14 16:50:43,568 INFO [NiFi logging handler]
>> org.apache.nifi.StdOut
>> > Queue Owner ---> APPS
>> > 2017-03-14 16:50:43,568 ERROR [NiFi logging handler]
>> org.apache.nifi.StdErr
>> > at oracle.AQ.AQDriverManager.createAQSession(AQDriverManager.
>> java:193)
>> > 2017-03-14 16:50:43,569 INFO [NiFi logging handler]
>> org.apache.nifi.StdOut
>> > QueueName ---> WF_BPEL_Q
>> > 2017-03-14 16:50:43,569 ERROR [NiFi logging handler]
>> org.apache.nifi.StdErr
>> > at
>> > com.oracle.xx.connector.processors.xx_SCon_ConsumeAQ.xx_
>> Scon_ConsumeAQ.createSession(xx_Scon_ConsumeAQ.java:183)
>> > 2017-03-14 16:50:43,569 INFO [NiFi logging handler]
>> org.apache.nifi.StdOut
>> > EventName ---> oracle.apps.ar.hz.CustAcctSite.update
>> > 2017-03-14 16:50:43,569 ERROR [NiFi logging handler]
>> org.apache.nifi.StdErr
>> > at
>> > com.oracle.xx.connector.processors.XX_SCon_ConsumeAQ.XX_
>> Scon_ConsumeAQ.onTrigger(XX_Scon_ConsumeAQ.java:254)
>> > 2017-03-14 16:50:43,569 INFO [NiFi logging handler]
>> org.apache.nifi.StdOut
>> > Consumer Name ---> ORA_69242HHG6SR4CGPI6KSJ8DI36T
>> > 2017-03-14 16:50:43,569 ERROR [NiFi logging handler]
>> org.apache.nifi.StdErr
>> > at
>> > org.apache.nifi.processor.AbstractProcessor.onTrigger(Abstra
>> ctProcessor.java:27)
>> > 2017-03-14 16:50:43,569 ERROR [NiFi logging handler]
>> org.apache.nifi.StdErr
>> > at
>> > org.apache.nifi.controller.StandardProcessorNode.onTrigger(S
>> tandardProcessorNode.java:1099)
>> > 2017-03-14 16:50:43,569 ERROR [NiFi logging handler]
>> org.apache.nifi.StdErr
>> > at
>> > org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask
>> .call(ContinuallyRunProcessorTask.java:136)
>> > 2017-03-14 16:50:43,570 ERROR [NiFi logging handler]
>> org.apache.nifi.StdErr
>> > at
>> > org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask
>> .call(ContinuallyRunProcessorTask.java:47)
>> > 2017-03-14 16:50:43,570 ERROR [NiFi logging handler]
>> org.apache.nifi.StdErr
>> > at
>> > org.apache.nifi.controller.scheduling.TimerDrivenSchedulingA
>> gent$1.run(TimerDrivenSchedulingAgent.java:132)
>> > 2017-03-14 16:50:43,570 ERROR [NiFi logging handler]
>> org.apache.nifi.StdErr
>> > at
>> > java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
>> > 2017-03-14 16:50:43,570 ERROR [NiFi logging handler]
>> org.apache.nifi.StdErr
>> > at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:
>> 308)
>> > 2017-03-14 16:50:43,570 ERROR [NiFi logging handler]
>> org.apache.nifi.StdErr
>> > at
>> > java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFu
>> tureTask.access$301(ScheduledThreadPoolExecutor.java:180)
>> > 2017-03-14 16:50:43,570 ERROR [NiFi logging handler]
>> org.apache.nifi.StdErr
>> > at
>> > java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFu
>> tureTask.run(ScheduledThreadPoolExecutor.java:294)
>> > 2017-03-14 16:50:43,570 ERROR [NiFi logging handler]
>> org.apache.nifi.StdErr
>> > at
>> > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPool
>> Executor.java:1142)
>> > 2017-03-14 16:50:43,570 ERROR [NiFi logging handler]
>> org.apache.nifi.StdErr
>> > at
>> > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoo
>> lExecutor.java:617)
>> > 2017-03-14 16:50:43,570 ERROR [NiFi logging handler]
>> org.apache.nifi.StdErr
>> > at java.lang.Thread.run(Thread.java:745)
>> > 2017-03-14 16:50:43,570 ERROR [NiFi logging handler]
>> org.apache.nifi.StdErr
>> > java.lang.NullPointerException
>> >
>> >
>> > On Wed, Mar 15, 2017 at 9:09 AM, Oleg Zhurakousky <
>> > [email protected]> wrote:
>> >
>> >> Anil
>> >>
>> >> Unfortunately the attachment didn’t come thru. Perhaps you can just
>> paste
>> >> the relevant part of the exception.
>> >>
>> >> Cheers
>> >> Oleg
>> >>
>> >> On Mar 15, 2017, at 8:58 AM, Anil Rai <[email protected]<mailto:
>> >> [email protected]>> wrote:
>> >>
>> >> Hi Oleg, Thanks. attached is the log. Let me know if you want us to
>> change
>> >> the log levels and re-run and send you additional logs?
>> >>
>> >>
>> >> On Tue, Mar 14, 2017 at 5:12 PM, Oleg Zhurakousky <
>> >> [email protected]<mailto:[email protected]>>
>> wrote:
>> >> Anil
>> >>
>> >> I understand that you are having an issue and we are here to help, but
>> we
>> >> can only do this if you help us just a little more, so it would be very
>> >> helpful if you provided a stack trace (I understand if you have to mask
>> >> sensitive information).
>> >> The “. . .fails saying cannot create AQSession. . .” could be due to
>> >> various reasons and until we see the stack trace everything here would
>> be
>> >> speculation.
>> >> I hope you understand
>> >>
>> >> Cheers
>> >> Oleg
>> >>
>> >>> On Mar 14, 2017, at 4:59 PM, Anil Rai <[email protected]<mailto:
>> >> [email protected]>> wrote:
>> >>>
>> >>> Here is the behaviour that we have seen so for....hope this helps
>> >>>
>> >>> 1. When we run the java code in eclipse, it works and this is the
>> >>> connection object that is printed ->
>> >>> oracle.jdbc.driver.T4CConnection@6f75e721
>> >>> 2. When we hard code all the values as mentioned in my first email
>> in a
>> >>> custom processor, deploy that. It works as well. The above connection
>> >>> object gets printed.
>> >>> 3. When we change the code in the custom processor to use the DBCP
>> >>> connection service, deploy that. The connection object that gets
>> >> printed is
>> >>> jdbc:oracle:thin:@oged-scan.og.ge.com:1521/ORPOGPB1<http:/
>> >> /jdbc:oracle:thin:@oged-scan.og.ge.com:1521/ORPOGPB1> and this does
>> not
>> >>> work. aqSession = AQDriverManager.createAQSession(connection) fails
>> >>> saying cannot create AQSession.
>> >>>
>> >>> Thanks
>> >>> Anil
>> >>>
>> >>>
>> >>> On Tue, Mar 14, 2017 at 4:13 PM, Oleg Zhurakousky <
>> >>> [email protected]<mailto:[email protected]>>
>> >> wrote:
>> >>>
>> >>>> Anil
>> >>>>
>> >>>> When you say "it does not like the connection object. . .” what do
>> you
>> >>>> mean by that?
>> >>>> Can you please provide stack trace or some other details?
>> >>>>
>> >>>> Cheers
>> >>>> Oleg
>> >>>>
>> >>>>> On Mar 14, 2017, at 4:06 PM, Anil Rai <[email protected]
>> <mailto:
>> >> [email protected]>> wrote:
>> >>>>>
>> >>>>> Thanks Russ. Yes, we are doing exactly the same thing.
>> >>>>>
>> >>>>> driverClass = context.getProperty(DRIVER_CLASS).getValue();
>> >>>>> queueName = context.getProperty(QUEUE_NAME).getValue();
>> >>>>> databaseSchema = context.getProperty(DATABASE_
>> >> SCHEMA).getValue();
>> >>>>> consumerName = context.getProperty(CONSUMER_NAME).getValue();
>> >>>>> eventName = context.getProperty(EVENT_NAME).getValue();
>> >>>>> DBCPService connection =
>> >>>>> context.getProperty(JDBC_CONNECTION_POOL).asControllerService(
>> >>>> DBCPService.class);
>> >>>>> Connection conn = connection.getConnection();
>> >>>>> * aqSession = AQDriverManager.createAQSession(connection);*
>> >>>>>
>> >>>>> The underlined code above fails as it does not like the connection
>> >> object
>> >>>>> that is returned by the DBCPService.
>> >>>>>
>> >>>>> Regards
>> >>>>> Anil
>> >>>>>
>> >>>>>
>> >>>>> On Tue, Mar 14, 2017 at 2:43 PM, Russell Bateman <
>> >> [email protected]<mailto:[email protected]>>
>> >>>>> wrote:
>> >>>>>
>> >>>>>> Anil,
>> >>>>>>
>> >>>>>> Typically, your custom processor should have a property, something
>> >> like
>> >>>>>>
>> >>>>>> public static final PropertyDescriptor DBCP_SERVICE = new
>> >>>>>> PropertyDescriptor.Builder()
>> >>>>>> .name("Database Connection Pooling Service")
>> >>>>>> .description("The Controller Service that is used to
>> obtain
>> >>>>>> connection to database")
>> >>>>>> .required(true)
>> >>>>>> .identifiesControllerService(DBCPService.class)
>> >>>>>> .build();
>> >>>>>>
>> >>>>>> When your NiFi user sets up the flow, he or she puts a reference to
>> >>>> NiFi's
>> >>>>>> DBCPConnectionPool in it. In configuring that (a ControllerService,
>> >> you
>> >>>>>> tell it that it's Oracle, location, etc.)
>> >>>>>>
>> >>>>>> Then, your onTrigger() code would do something like this:
>> >>>>>>
>> >>>>>> final DBCPService dbcpService = context.getProperty(DBCP_SERVI
>> >>>>>> CE).asControllerService(DBCPService.class);
>> >>>>>>
>> >>>>>>
>> >>>>>> and later...
>> >>>>>>
>> >>>>>>
>> >>>>>> try (final Connection connection =
>> dbcpService.getConnection())
>> >>>>>> {
>> >>>>>> try (final Statement stmt = connection.createStatement(
>> >>>> ResultSet.TYPE_FORWARD_ONLY,
>> >>>>>> ResultSet.CONCUR_READ_ONLY))
>> >>>>>>
>> >>>>>> etc.
>> >>>>>>
>> >>>>>> Does this help?
>> >>>>>>
>> >>>>>> Russ
>> >>>>>>
>> >>>>>>
>> >>>>>>
>> >>>>>> On 03/14/2017 11:54 AM, Anil Rai wrote:
>> >>>>>>
>> >>>>>>> We have a use case to connect to oracle database and subscribe to
>> >>>> Advanced
>> >>>>>>> Queuing (https://docs.oracle.com/cd/A58617_01/server.804/a58241/
>> >>>> ch_aq.htm
>> >>>>>>> ).
>> >>>>>>> Below is the java snippet to establish this connection from a java
>> >>>> client.
>> >>>>>>> We can run this in eclipse and consume message from the advanced
>> >> queue.
>> >>>>>>> **************
>> >>>>>>> Class.forName("oracle.jdbc.driver.OracleDriver");
>> >>>>>>> connection = DriverManager.getConnection("
>> >>>>>>> jdbc:oracle:thin:@xxx-yyy.zzz.com:1521/DB1<http://jdbc:
>> >> oracle:thin:@xxx-yyy.zzz.com:1521/DB1>","user", "pwd");
>> >>>>>>> connection.setAutoCommit(true);
>> >>>>>>> Class.forName("oracle.AQ.AQOracleDriver");
>> >>>>>>> aqSession = AQDriverManager.createAQSessio
>> n(connection);
>> >>>>>>> System.out.println("AQ Session --->" + aqSession);
>> >>>>>>> ********************
>> >>>>>>>
>> >>>>>>> We have created a custom processor in Nifi. This processor is
>> getting
>> >>>> the
>> >>>>>>> connection string using getConnection function of Standard DBCP
>> >>>> service.
>> >>>>>>> The problem is, the connection object that is retrieved from
>> eclipse
>> >>>>>>> versus
>> >>>>>>> what is returned from DBCP service is different. We have made
>> sure we
>> >>>> are
>> >>>>>>> referring to the same jar both in eclipse and Nifi (ojdbc7.jar)
>> >>>>>>> It fails @ aqSession = AQDriverManager.createAQSessio
>> n(connection);
>> >>>>>>> The connection object that comes from DBCP is not what is
>> expected by
>> >>>>>>> AQDriverManager.
>> >>>>>>>
>> >>>>>>> Any help is greatly appreciated.
>> >>>>>>>
>> >>>>>>> Thanks
>> >>>>>>> Anil
>> >>>>>>>
>> >>>>>>>
>> >>>>>>
>> >>>>
>> >>>>
>> >>
>> >>
>> >>
>> >>
>>
>>
>
Java Code :
aDBCPService d =
context.getProperty(DBC_SERVICE).asControllerService(DBCPService.class);
Connection dbConnection= d.getConnection();
DelegatingConnection dc = (DelegatingConnection)dbConnection;
OracleConnection oc = (OracleConnection)dc.getInnermostDelegate();
System.out.println("*** DB COnnection Established.. " + dbConnection);
System.out.println("OracleConnection Got "+oc);
System.out.println("UnderLyingConnection Got
"+dc.getInnermostDelegate());
//getLogger().info("DB Connection Established "+dbConnection);
CallableStatement callableStatement = null;
//OracleCallableStatement callableStatement =null;
String execSubmitOrderSP =
"{call
apps.Gets_Www_Cwc_Erp_Qry_Pkg.Submit_Order(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)}";
FlowFile queryflowfile = session.create();
try {
callableStatement = dbConnection.prepareCall(execSubmitOrderSP);
//dbConnection =
DriverManager.getConnection("jdbc:oracle:thin:@abc.xyz.efg.com:1551:dev1","user","pwd");
System.out.println("CallableStatement "+callableStatement);
//callableStatement =
(OracleCallableStatement)dbConnection.prepareCall(execSubmitOrderSP);
if (dbConnection.isWrapperFor(OracleConnection.class)){
// OracleConnection oracleConnection=
dbConnection.unwrap(OracleConnection.class);
System.out.println("dbConnection.isWrapperFor(OracleConnection.class) is
!!!!!!!!!!");
}else{
// recover, not an oracle connection
System.out.println("no");
}
//set input parameters here
Object[] lineItem;
lineItem = new Object[] { new Integer(1), "905-001533-0",
"41D728627G2", "TestItem", new Integer(10), "USD", "Dummy", new Integer(1), new
Integer(4), new Integer(10), new Integer(20),"Yes",
"Dummyitem_type", "Y", "PRICED", new
Integer(100), "Y", "EA", "11", "du", "4", "Dummy Item", new java.sql.Date(0)};
Object[] lineItemArray;
lineItemArray = new Object[]{lineItem, lineItem};
System.out.println("lineItemArray "+lineItemArray);
System.out.println("BEGINNING OF CALLABLE STATEMENT AND RESULT");
DatabaseMetaData metadata = dbConnection.getMetaData();
System.out.println("DB product: " +
metadata.getDatabaseProductName());
System.out.println("JDBC Driver: " + metadata.getDriverName());
System.out.println("AFTER OF CALLABLE STATEMENT AND RESULT");
if (!(dbConnection instanceof OracleConnection)) {
//dbConnection = dbConnection.unwrap(OracleConnection.class);
System.out.println("No it is instance of OracleConnection");
}
//dbConnection = dbConnection.unwrap(java.sql.Connection.class);
@SuppressWarnings("deprecation")
ArrayDescriptor des =
ArrayDescriptor.createDescriptor("GETS_WWW_CWC_ORDER_ITM_DET_NT", dbConnection);
@SuppressWarnings("deprecation")
ARRAY array_to_pass = new ARRAY(des, dbConnection, lineItemArray);
output:
2017-03-15 22:19:21,626 INFO
[NiFi logging handler] org.apache.nifi.StdOut *** DB COnnection Established..
jdbc:oracle:thin:@trodev1vn01.trans.ge.com:1551:tsoadev1, UserName=APPS, Oracle
JDBC driver
2017-03-15 22:19:21,626 INFO
[NiFi logging handler] org.apache.nifi.StdOut OracleConnection Got null
2017-03-15 22:19:21,626 INFO
[NiFi logging handler] org.apache.nifi.StdOut UnderLyingConnection Got null
2017-03-15 22:19:21,804 INFO
[NiFi logging handler] org.apache.nifi.StdOut CallableStatement
oracle.jdbc.driver.OracleCallableStatementWrapper@29dd4a78
2017-03-15 22:19:21,804 INFO
[NiFi logging handler] org.apache.nifi.StdOut
dbConnection.isWrapperFor(OracleConnection.class) is !!!!!!!!!!
2017-03-15 22:19:21,805 INFO
[NiFi logging handler] org.apache.nifi.StdOut lineItemArray
[Ljava.lang.Object;@34a402dc
2017-03-15 22:19:21,805 INFO
[NiFi logging handler] org.apache.nifi.StdOut BEGINNING OF CALLABLE STATEMENT
AND RESULT
2017-03-15 22:19:21,808 INFO
[NiFi logging handler] org.apache.nifi.StdOut DB product: Oracle
2017-03-15 22:19:21,808 INFO
[NiFi logging handler] org.apache.nifi.StdOut JDBC Driver: Oracle JDBC driver
2017-03-15 22:19:21,808 INFO
[NiFi logging handler] org.apache.nifi.StdOut AFTER OF CALLABLE STATEMENT AND
RESULT
2017-03-15 22:19:21,808 INFO
[NiFi logging handler] org.apache.nifi.StdOut No it is instance of
OracleConnection
Error
java.lang.ClassCastException:
org.apache.commons.dbcp.PoolingDataSource$PoolGuardConnectionWrapper cannot be
cast to oracle.jdbc.OracleConnection
at
oracle.sql.ArrayDescriptor.createDescriptor(ArrayDescriptor.java:106)
~[ojdbc7.jar:12.1.0.2.0]
at oracle.sql.ArrayDescriptor.createDescriptor(ArrayDescriptor.java:74)
~[ojdbc7.jar:12.1.0.2.0]
at ge.processors.sbo.GESBOProcessor.onTrigger(GESBOProcessor.java:183)
~[nifi-sbo-processors-0.4.0.jar:0.4.0]
at
org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27)
~[nifi-api-1.1.1.jar:1.1.1]
at
org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1099)
[nifi-framework-core-1.1.1.jar:1.1.1]
at
org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:136)
[nifi-framework-core-1.1.1.jar:1.1.1]
at
org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:47)
[nifi-framework-core-1.1.1.jar:1.1.1]
at
org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:132)
[nifi-framework-core-1.1.1.jar:1.1.1]
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
[na:1.8.0_91]
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
[na:1.8.0_91]
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
[na:1.8.0_91]
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
[na:1.8.0_91]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
[na:1.8.0_91]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
[na:1.8.0_91]
at java.lang.Thread.run(Thread.java:745) [na:1.8.0_91]
2017-03-15 22:19:21,950 ERROR [Timer-Driven Process Thread-4]
ge.processors.sbo.GESBOProcessor
GESBOProcessor[id=d2dbfc50-015a-1000-771f-557e06902528]
GESBOProcessor[id=d2dbfc50-015a-1000-771f-557e06902528] failed to process
session due to java.lang.ClassCastException:
org.apache.commons.dbcp.PoolingDataSource$PoolGuardConnectionWrapper cannot be
cast to oracle.jdbc.OracleConnection: java.lang.ClassCastException:
org.apache.commons.dbcp.PoolingDataSource$PoolGuardConnectionWrapper cannot be
cast to oracle.jdbc.OracleConnection
2017-03-15 22:19:21,962 ERROR [Timer-Driven Process Thread-4]
ge.processors.sbo.GESBOProcessor
java.lang.ClassCastException:
org.apache.commons.dbcp.PoolingDataSource$PoolGuardConnectionWrapper cannot be
cast to oracle.jdbc.OracleConnection
at
oracle.sql.ArrayDescriptor.createDescriptor(ArrayDescriptor.java:106)
~[ojdbc7.jar:12.1.0.2.0]
at oracle.sql.ArrayDescriptor.createDescriptor(ArrayDescriptor.java:74)
~[ojdbc7.jar:12.1.0.2.0]
at ge.processors.sbo.GESBOProcessor.onTrigger(GESBOProcessor.java:183)
~[na:na]
at
org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27)
~[nifi-api-1.1.1.jar:1.1.1]
at
org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1099)
~[nifi-framework-core-1.1.1.jar:1.1.1]
at
org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:136)
[nifi-framework-core-1.1.1.jar:1.1.1]
at
org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:47)
[nifi-framework-core-1.1.1.jar:1.1.1]
at
org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:132)
[nifi-framework-core-1.1.1.jar:1.1.1]
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
[na:1.8.0_91]
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
[na:1.8.0_91]
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
[na:1.8.0_91]
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
[na:1.8.0_91]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
[na:1.8.0_91]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
[na:1.8.0_91]
at java.lang.Thread.run(Thread.java:745) [na:1.8.0_91]
2017-03-15 22:19:21,962 WARN [Timer-Driven Process Thread-4]
ge.processors.sbo.GESBOProcessor
GESBOProcessor[id=d2dbfc50-015a-1000-771f-557e06902528] Processor
Administratively Yielded for 1 sec due to processing failure
2017-03-15 22:19:21,962 WARN [Timer-Driven Process Thread-4]
o.a.n.c.t.ContinuallyRunProcessorTask Administratively Yielding
GESBOProcessor[id=d2dbfc50-015a-1000-771f-557e06902528] due to uncaught
Exception: java.lang.ClassCastException:
org.apache.commons.dbcp.PoolingDataSource$PoolGuardConnectionWrapper cannot be
cast to oracle.jdbc.OracleConnection
2017-03-15 22:19:21,964 WARN [Timer-Driven Process Thread-4]
o.a.n.c.t.ContinuallyRunProcessorTask
java.lang.ClassCastException:
org.apache.commons.dbcp.PoolingDataSource$PoolGuardConnectionWrapper cannot be
cast to oracle.jdbc.OracleConnection
at
oracle.sql.ArrayDescriptor.createDescriptor(ArrayDescriptor.java:106)
~[ojdbc7.jar:12.1.0.2.0]
at oracle.sql.ArrayDescriptor.createDescriptor(ArrayDescriptor.java:74)
~[ojdbc7.jar:12.1.0.2.0]
at ge.processors.sbo.GESBOProcessor.onTrigger(GESBOProcessor.java:183)
~[na:na]
at
org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27)
~[nifi-api-1.1.1.jar:1.1.1]
at
org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1099)
~[nifi-framework-core-1.1.1.jar:1.1.1]
at
org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:136)
[nifi-framework-core-1.1.1.jar:1.1.1]
at
org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:47)
[nifi-framework-core-1.1.1.jar:1.1.1]
at
org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:132)
[nifi-framework-core-1.1.1.jar:1.1.1]
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
[na:1.8.0_91]
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
[na:1.8.0_91]
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
[na:1.8.0_91]
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
[na:1.8.0_91]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
[na:1.8.0_91]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
[na:1.8.0_91]
at java.lang.Thread.run(Thread.java:745) [na:1.8.0_91]
