apex-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Chaitanya Chebolu <chaita...@datatorrent.com>
Subject Re: Issue when Launching apps having KafkaInput
Date Mon, 29 Aug 2016 11:44:09 GMT
Hi John,

  From the debug message, value of zookeeperMap is null. You need to set
the zookeeper property.
  Which version of Malhar are you using?

Regards,
Chaitanya


On Mon, Aug 29, 2016 at 3:15 PM, JOHN, BIBIN <bj9306@att.com> wrote:

> Team,
>
> Could you please help me to debug this issue?
>
>
>
>
>
> An error occurred trying to launch the application. Server message:
> javax.validation.ConstraintViolationException: Operator kafkainput
> violates constraints [ConstraintViolationImpl{
> rootBean=com.att.dti.dtdemo1.app.Application$KafkaInput@5a04a4b6,
> propertyPath='consumer.zookeeperMap', message='may not be null',
> leafBean=com.datatorrent.contrib.kafka.SimpleKafkaConsumer@768e3249,
> value=null}] at com.datatorrent.stram.plan.logical.LogicalPlan.validate(LogicalPlan.java:1674)
> at com.datatorrent.stram.StramClient.<init>(StramClient.java:163) at
> com.datatorrent.stram.client.StramAppLauncher.launchApp(StramAppLauncher.java:596)
> at com.datatorrent.stram.cli.ApexCli$LaunchCommand.execute(ApexCli.java:2056)
> at com.datatorrent.stram.cli.ApexCli.launchAppPackage(ApexCli.java:3445)
> at com.datatorrent.stram.cli.ApexCli.access$7400(ApexCli.java:151) at
> com.datatorrent.stram.cli.ApexCli$LaunchCommand.execute(ApexCli.java:1900)
> at com.datatorrent.stram.cli.ApexCli$3.run(ApexCli.java:1462)
>
>
>
>
>
>
>
> *Thanks and Regards,*
>
> *Bibin John| Data Movement Technology Development*
>
> *20205 North Creek Pkwy , Bothell, WA 98011 USA*
>
> *(* *Office: (770) 235 5614 | Cell: (469) 648-9858*
>
> *Email: *bj9306@att.com
>
>
>
> OOO Alert :  09/19/2016 – 10/14/2016
>
>
>
>
>
>
>

Mime
View raw message