apex-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Max Bridgewater <max.bridgewa...@gmail.com>
Subject Re: java.lang.NoClassDefFoundError: com/github/fge/jsonschema/exceptions/ProcessingException
Date Fri, 02 Dec 2016 20:32:42 GMT
Thanks a lot. I ended up implementing my JSONParser operator. It makes
sense as I will likely add some custom stuff fthere.

On Fri, Dec 2, 2016 at 12:09 AM, Priyanka Gugale <priyag@apache.org> wrote:

> Hi Max,
>
> You need "json-schema-validator" in your project pom as Ashwin suggested.
> In contrib project this dependency is marked as optional so it won't be
> included by default unless you include it explicitly from your application
> pom.
>
> Ashwin,
> We should remove optional tag from examples project. But it doesn't cause
> problems, the jar is still bundled in "apa" package.
>
> -Priyanka
>
> On Fri, Dec 2, 2016 at 5:48 AM, Ashwin Chandra Putta <
> ashwinchandrap@gmail.com> wrote:
>
>> Max,
>>
>> Seems like you need to add the following dependency.
>>
>>     <dependency>
>>       <groupId>com.github.fge</groupId>
>>       <artifactId>json-schema-validator</artifactId>
>>       <version>2.0.1</version>
>>     </dependency>
>>
>> See the following example, but it is marked as optional so not sure if it
>> is really required.
>>
>> https://github.com/DataTorrent/examples/blob/master/
>> tutorials/parser/pom.xml
>>
>> Shubham, Priyanka,
>>
>> Any thoughts?
>>
>> Regards,
>> Ashwin.
>>
>> On Thu, Dec 1, 2016 at 11:14 AM, Max Bridgewater <
>> max.bridgewater@gmail.com> wrote:
>>
>>> I am trying to use the Malhar JSonParser. My code goes like this:
>>>
>>>
>>>   KafkaSinglePortInputOperator in = dag.addOperator("kafkaIn", new
>>> KafkaSinglePortInputOperator());
>>>     in.setInitialOffset(AbstractKafkaInputOperator.InitialOffset
>>> .EARLIEST.name());
>>>     JsonParser parser= dag.addOperator("jsonParser",new JsonParser());
>>>     LineOutputOperator out = dag.addOperator("fileOut", new
>>> LineOutputOperator());
>>>     dag.addStream("parse", in.outputPort, parser.in);
>>>     dag.addStream("data",parser.out , out.input);
>>>
>>>
>>> However, when I deploy it , I get following exception. This seems to be
>>> a guava class. Am I supposed to add guava as dependency in my app? I
>>> thought all of  contrib dependencies are provided by the Apex runtime
>>> environment. Any thoughts?
>>>
>>>
>>> the application. Server message: java.lang.NoClassDefFoundError:
>>> com/github/fge/jsonschema/exceptions/ProcessingException
>>> at com.example.myapexapp.KafkaApp.populateDAG(KafkaApp.java:24)
>>> at com.datatorrent.stram.plan.logical.LogicalPlanConfiguration.
>>> prepareDAG(LogicalPlanConfiguration.java:2226)
>>> at com.datatorrent.stram.client.StramAppLauncher$1.createApp(St
>>> ramAppLauncher.java:490)
>>> at com.datatorrent.stram.client.StramAppLauncher.launchApp(Stra
>>> mAppLauncher.java:601)
>>> at com.datatorrent.stram.cli.ApexCli$LaunchCommand.execute(Apex
>>> Cli.java:2062)
>>> at com.datatorrent.stram.cli.ApexCli.launchAppPackage(ApexCli.java:3451)
>>> at com.datatorrent.stram.cli.ApexCli.access$7400(ApexCli.java:153)
>>> at com.datatorrent.stram.cli.ApexCli$LaunchCommand.execute(Apex
>>> Cli.java:1906)
>>> at com.datatorrent.stram.cli.ApexCli$3.run(ApexCli.java:1468)
>>> Caused by: java.lang.ClassNotFoundException:
>>> com.github.fge.jsonschema.exceptions.ProcessingException
>>> at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
>>> at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
>>> at java.net.FactoryURLClassLoader.loadClass(URLClassLoader.java:814)
>>> at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
>>> ... 9 more
>>>
>>
>>
>>
>> --
>>
>> Regards,
>> Ashwin.
>>
>
>

Mime
View raw message