apex-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Munagala Ramanath <...@datatorrent.com>
Subject Re: Jdbcoutputoperator implementation
Date Thu, 23 Jun 2016 22:32:42 GMT
Please look at:

http://docs.datatorrent.com/beginner/ and
http://docs.datatorrent.com/application_packages/

for examples on how to set properties from XML files.

Ram

On Thu, Jun 23, 2016 at 3:25 PM, Jaikit Jilka <jjilka@leadferret.com> wrote:

> Hello,
>
> How to pass an empty string for updatecommand in properties.xml.
> When I change my malhar version to 3.5.0-SNAPSHOT it gives me a complie
> time error -Failure to find
> org.apache.apex:malhar-library:jar:3.5.0-SNAPSHOT in
> https://www.datatorrent.com/maven/content/repositories/snapshots/
>
> Thank You,
>
> Jaikit Jilka
>
> ----- Original Message -----
> From: "Pradeep A. Dalvi" <prad@apache.org>
> To: "users" <users@apex.apache.org>
> Sent: Thursday, June 23, 2016 12:43:40 PM
> Subject: Re: Jdbcoutputoperator implementation
>
> Hi Jaikit,
>
> This constraint violation exception was enforced from
> AbstractJdbcTransactionableOutputOperator. In 3.3/3.4 malhar library,
> updateCommand parameter has constraint set to @NotNull on getter
> method.
>
> You could do either of following to solve this:
> 1. Set updateCommand from properties.xml to empty string
> 2. Use master branch of Malhar
> 3. Remove @NotNull on getUpdateCommand in
> AbstractJdbcTransactionableOutputOperator
>
> Cheers,
> Pradeep A. Dalvi
>
> On Thu, Jun 23, 2016 at 11:36 AM, Jaikit Jilka <jjilka@leadferret.com>
> wrote:
> > 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" <devendrat@datatorrent.com>
> > To: "users" <users@apex.apache.org>
> > 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 <jjilka@leadferret.com>
> > 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
>

Mime
View raw message