Re: JDBCtoJDBC Example

2016-12-21 Thread Munagala Ramanath
016 at 2:43 AM, JOHN, BIBIN <bj9...@att.com> wrote: > >> Anyone have idea on this? >> >> >> >> *From:* JOHN, BIBIN >> *Sent:* Monday, December 19, 2016 7:05 PM >> *To:* 'users@apex.apache.org' <users@apex.apache.org> >> *Subject:* RE: JD

Re: JDBCtoJDBC Example

2016-12-21 Thread Bhupesh Chawda
, 2016 at 2:43 AM, JOHN, BIBIN <bj9...@att.com> wrote: > Anyone have idea on this? > > > > *From:* JOHN, BIBIN > *Sent:* Monday, December 19, 2016 7:05 PM > *To:* 'users@apex.apache.org' <users@apex.apache.org> > *Subject:* RE: JDBCtoJDBC Example > &g

RE: JDBCtoJDBC Example

2016-12-19 Thread JOHN, BIBIN
@apex.apache.org Subject: Re: JDBCtoJDBC Example Hi, Could you please ping how you are providing the mapping between the POJO types and sql types in your application. you can also enable debug and log the value of columnDataTypes (see populateColumnDataTypes method) in JdbcPOJOInputOperator

Re: JDBCtoJDBC Example

2016-12-19 Thread Devendra Tagare
.java:activate(178)) > - Catching up from 1482184295500 to 1482184311524 > > 2016-12-19 13:51:53,548 INFO engine.StreamingContainer > (StreamingContainer.java:processHeartbeatResponse(799)) - Undeploy > request: [1, 2] > > 2016-12-19 13:51:53,549 INFO engine.StreamingContain

RE: JDBCtoJDBC Example

2016-12-19 Thread JOHN, BIBIN
Creek Pkwy , Bothell, WA 98011 USA • Office: (770) 235 5614 | Cell: (469) 648-9858 Email: bj9...@att.com<mailto:bj9...@att.com> From: Devendra Tagare [mailto:devend...@datatorrent.com] Sent: Monday, December 19, 2016 1:05 PM To: users@apex.apache.org Subject: Re: JDBCtoJDBC Examp

Re: JDBCtoJDBC Example

2016-12-19 Thread Devendra Tagare
Hi, properties.xml seems to indicate that the databaseUrl is of the form jdbc:oracle:thin:@//host:port/db Can you try setting the databaseUrl to the below format which OracleDriver recommends - here

JDBCtoJDBC Example

2016-12-19 Thread JOHN, BIBIN
All, I am getting below exception for JDBC to JDBC example and hitting below error. I have verified the table and it exist in DB. I have attached the property file. Please help on this. 2016-12-19 11:07:32,186 INFO storage.DiskStorage (DiskStorage.java:(53)) - using