Hi Devendra,
I tried to run your application. I followed all steps mentioned but I am
getting following error.
An error occurred trying to launch the application. Server message:
javax.validation.ConstraintViolationException: Operator JdbcOutput violates
constraints
[ConstraintViolationImpl{rootBean=JdbcPOJOOutputOperator{name=null},
propertyPath='updateCommand', message='may not be null',
leafBean=JdbcPOJOOutputOperator{name=null}, value=null}] at
com.datatorrent.stram.plan.logical.LogicalPlan.validate(LogicalPlan.java:1680)
at com.datatorrent.stram.StramClient.<init>(StramClient.java:161) at
com.datatorrent.stram.client.StramAppLauncher.launchApp(StramAppLauncher.java:509)
at com.datatorrent.stram.cli.DTCli$LaunchCommand.execute(DTCli.java:2050) at
com.datatorrent.stram.cli.DTCli.launchAppPackage(DTCli.java:3456) at
com.datatorrent.stram.cli.DTCli.access$7100(DTCli.java:106) 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" <[email protected]>
To: "users" <[email protected]>
Sent: Thursday, June 23, 2016 10:32:17 AM
Subject: Re: Jdbcoutputoperator implementation
Hi Jalkit,
The JdbcPOJOOutputOperator is being configured with the
JdbcTransactionalStore which requires an additional dt_meta table.
The table schema is here -
https://github.com/devtagare/examples/blob/SPOI-8251/tutorials/jdbcToJdbc/src/test/resources/example.sql
You can find an example application which uses the JdbcPOJOOutputOperator
here -
https://github.com/devtagare/examples/tree/SPOI-8251/tutorials/jdbcToJdbc
Thanks,
Dev
On Thu, Jun 23, 2016 at 10:17 AM, Jaikit Jilka <[email protected]>
wrote:
> Hello,
>
> I am currently working on an application which simply read data from .txt
> file and slpits the words and inserts them into mysql. But I am getting
> error. I am using jdbcpojooutputoperator from malhar library. But I am
> getting an error on ActiveFieldInfos which says it is protected in
> jdbcpojoinputoperator and also I do not know what to do in Application.java
> file. I am attaching both the file here. Kindly help me resolve the issue.
>
> Thank You,
>
> Jaikit Jilka
