I remember the jdbc pojo input operator did only batch read (only existing records at the time of start of the operator) and not continuous polling of subsequent records. Not sure if this is fixed?
Can you try the polling input operator? https://github.com/devtagare/examples/tree/master/tutorials/JdbcIngest Regards, Ashwin. On Thu, Jul 21, 2016 at 11:11 AM, Pradeep A. Dalvi <[email protected]> wrote: > What happens if you remove JDBC Output Operator and write to console or > something, do you still observe the similar behavior? > > --prad > > On Thu, Jul 21, 2016 at 10:58 AM, Jaikit Jilka <[email protected]> > wrote: > >> Hello, >> >> I am referring to JdbcPojoImput operator. when I launch the application >> it emits around 500records/sec but once it reaches 30k it slows down and >> emits 15records/sec. I inserting record from a table which has data coming >> in continously and after the data is parsed I am deleting the record from >> source table. But this is not the issue because I tried removing delete >> query and still gives me same error. >> >> ----- Original Message ----- >> From: "Ashwin Chandra Putta" <[email protected]> >> To: "users" <[email protected]> >> Sent: Thursday, July 14, 2016 6:41:18 PM >> Subject: Re: Operators not working >> >> When you say it does not emit anything, are you referring to your input >> operator? Is it an operator from malhar? Which one? >> >> And how many records do you have in the source table? >> >> Regards, >> Ashwin. >> >> On Jul 14, 2016 3:55 PM, "Jaikit Jilka" <[email protected]> wrote: >> >> > Hello, >> > >> > I am parsing data from one table to another table. My operators are >> > running but it does not parse or emit anything after it parses 50000 >> rows. >> > I also partitioned my parser operator and jdbcoutput operator. It 50000 >> it >> > works fine and later it slows down and finally it does not emit >> anything. >> > Latency of the operator is also around 120 - 150. What can be wrong >> here. >> > >> > Thank You, >> > Jaikit JIlka >> > >> > > -- Regards, Ashwin.
