apex-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Munagala Ramanath <...@datatorrent.com>
Subject Re: Apex engine and malhar maven versions for Kafka 0.9 version operator
Date Sun, 17 Apr 2016 03:24:12 GMT
Ananth,

Could you make your pom.xml accessible somewhere ?

Ram

On Sat, Apr 16, 2016 at 3:30 PM, Ananth Gundabattula <
agundabattula@gmail.com> wrote:

> Hello all,
>
> I would like to run a unit test code using the new Kafka Operator that
> supports the 0.9 version protocol.
>
> In this process, I included the malhar-kafka library version (
> 3.3.1-incubating ) and am using the apex-engine ( version 3.3.0 ) with
> <scope> as test/provided.
>
> The compilation works fine but my unit tests fail to run properly with "
> java.lang.ClassNotFoundException: com.datatorrent.lib.util.KryoCloneUtils"
> exception.
>
>
> What is the recommended way to run a unit test which uses Kafka 0.9
> operator integrated with the Apex engine ? I am assuming that the
> malhar-contrib library kafka operator is not 0.9 compliant ..
>
> The unit test code is like this :
>
> The class CassandraEventDetailsStreamingApp extends the
> AbstractKafkaInputOperator in the below snippet of code.
>
> The exception arises in the method lma.getController();
>
> @Test
> public void testApplication() throws IOException, Exception {
>     try {
>         LocalMode lma = LocalMode.newInstance();
>         Configuration conf = new Configuration(false);
>         conf.addResource(this.getClass().getResourceAsStream("/dag-test-props.xml"));
>         lma.prepareDAG(new CassandraEventDetailsStreamingApp(), conf);
>         LocalMode.Controller lc = lma.getController();
>         lc.run();
>     } catch (ConstraintViolationException e) {
>         Assert.fail("constraint violations: " + e.getConstraintViolations());
>     }
> }
>
>
>
> Regards,
> Ananth
>

Mime
View raw message