Latency issue

2016-11-16 Thread Jaikit Jilka
Hello, I have a parser operator which parses data from a JSON file. But when I use small size JOSN file its latency is very less and if I use large size JSON file its latency keeps on increasing. is there any way I can control the latency of the operator. Thank you, Jaikit Jilka

Read files from SFTP

2016-10-19 Thread Jaikit Jilka
tring". and if i change SFTP to FTP than it gives me following error: MalformedServerReplyException: cannot parse response code What am i doing wrong here. Thank You, Jaikit Jilka

Reading from AWS S3

2016-09-28 Thread Jaikit Jilka
run my application it is giving me an error saying bucket name should be between 3 and 63 character. I have checked my access key and secret key. I do not know what is the issue. Can anyone help me with this. Thank you, Jaikit Jilka

MongoDB Example

2016-09-13 Thread Jaikit Jilka
Hello, I am looking for an example application which uses MongoDB input oprator and MongoDB output operator. Can anyone share the link if it is available. Thank you, Jaikit Jilka

Re: Kyrp exception

2016-09-07 Thread Jaikit Jilka
s that a resultSet field is part of the checkpointed state. I don't see this property in the latest release (3.5.0). Which version of Malhar are you using? On Wed, Sep 7, 2016 at 2:16 PM, Jaikit Jilka <jji...@leadferret.com> wrote: > Hello, > > I did not clearly understand you question but in JDBC

Re: A proposal for Malhar

2016-07-28 Thread Jaikit Jilka
adding the properties manually in the console it failed. What might be the reason for such behavior? Thank You, Jaikit Jilka - Original Message - From: "Lakshmi Velineni" <laks...@datatorrent.com> To: "users" <users@apex.apache.org> Sent: Thursday, July

Operators not working

2016-07-14 Thread Jaikit Jilka
anything. Latency of the operator is also around 120 - 150. What can be wrong here. Thank You, Jaikit JIlka

Re: Jdbcoutputoperator implementation

2016-07-07 Thread Jaikit Jilka
Hello, It is running fine now. Got expected results. Thank you - Original Message - From: "Jaikit Jilka" <jji...@leadferret.com> To: "users" <users@apex.apache.org> Sent: Thursday, July 7, 2016 12:55:58 PM Subject: Re: Jdbcoutputoperator implementatio

Re: Jdbcoutputoperator implementation

2016-06-28 Thread Jaikit Jilka
xpects data as POJO, whose class name is specified using Context.PortContext.TUPLE_CLASS i.e. com.mycompany.test.PojoEvent here. Previous operator is probably sending String to JdbcPOJOOutputOperator. On Tue, Jun 28, 2016 at 4:16 PM, Jaikit Jilka <jji...@leadferret.com> wrote: > Hel

Re: Jdbcoutputoperator implementation

2016-06-28 Thread Jaikit Jilka
putoperator implementation What is the type of data emitted by previous operator to JdbcPOJOOutputOperator? On Tue, Jun 28, 2016 at 3:46 PM, Jaikit Jilka <jji...@leadferret.com> wrote: > Hello, > > I am getting an error as follow: > > Stopped running due to an exception. jav

Re: Jdbcoutputoperator implementation

2016-06-28 Thread Jaikit Jilka
where to check the cast mismatch. I am inserting a value in the database. Thank You, Jaikit Jilka - Original Message - From: "Pradeep A. Dalvi" <p...@apache.org> To: "users" <users@apex.apache.org> Sent: Friday, June 24, 2016 4:45:18 PM Subject: Re: J

Re: Jdbcoutputoperator implementation

2016-06-23 Thread Jaikit Jilka
) at com.datatorrent.stram.cli.DTCli$LaunchCommand.execute(DTCli.java:1895) at com.datatorrent.stram.cli.DTCli$3.run(DTCli.java:1449) Thank you, Jaikit Jilka - Original Message - From: "Devendra Tagare" <devend...@datatorrent.com> To: "users" <users@apex.apa