search

miguno / kafka-storm-starter

[PROJECT IS NO LONGER MAINTAINED] Code examples that show to integrate Apache Kafka 0.8+ with Apache Storm 0.9+ and Apache Spark Streaming 1.1+, while using Apache Avro as the data serialization format.
http://www.michael-noll.com/blog/2014/05/27/kafka-storm-integration-example-tutorial/
Other
725 stars 330 forks source link

Failed to run "sbt test" #11

Closed francotestori closed 8 years ago

francotestori commented 8 years ago

After running sbt test on my computer the error code posted here appears. Yet it is strange because I have succesfully run this code on my personal computer. I would believe there is an issue related to the generated code from the avro schema, but it is only an assumption.

I would really appreciate some help with this issue. Thanks in advanced.

P.S: Here goes the error code

[info] Loading project definition from /home/franco/sandbox/kafka-storm-starter/project
[info] Set current project to kafka-storm-starter (in build file:/home/franco/sandbox/kafka-storm-starter/)
[info] Compiling 12 Scala sources to /home/franco/sandbox/kafka-storm-starter/target/scala-2.10/test-classes...
[error] 
[error]      while compiling: /home/franco/sandbox/kafka-storm-starter/src/test/scala/com/miguno/kafkastorm/testing/EmbeddedKafkaZooKeeperCluster.scala
[error]         during phase: jvm
[error]      library version: version 2.10.5
[error]     compiler version: version 2.10.5
[error]   reconstructed args: -classpath /home/franco/sandbox/kafka-storm-starter/target/scala-2.10/test-classes:/home/franco/sandbox/kafka-storm-starter/target/scala-2.10/classes:/home/franco/.ivy2/cache/org.apache.avro/avro-compiler/bundles/avro-compiler-1.7.7.jar:/home/franco/.ivy2/cache/org.apache.avro/avro/jars/avro-1.7.7.jar:/home/franco/.ivy2/cache/org.codehaus.jackson/jackson-core-asl/jars/jackson-core-asl-1.9.13.jar:/home/franco/.ivy2/cache/org.codehaus.jackson/jackson-mapper-asl/jars/jackson-mapper-asl-1.9.13.jar:/home/franco/.ivy2/cache/org.apache.commons/commons-compress/jars/commons-compress-1.4.1.jar:/home/franco/.ivy2/cache/org.tukaani/xz/jars/xz-1.0.jar:/home/franco/.ivy2/cache/commons-lang/commons-lang/jars/commons-lang-2.6.jar:/home/franco/.ivy2/cache/org.apache.velocity/velocity/jars/velocity-1.7.jar:/home/franco/.ivy2/cache/commons-collections/commons-collections/jars/commons-collections-3.2.1.jar:/home/franco/.ivy2/cache/com.twitter/bijection-core_2.10/bundles/bijection-core_2.10-0.7.1.jar:/home/franco/.ivy2/cache/com.twitter/bijection-avro_2.10/bundles/bijection-avro_2.10-0.7.1.jar:/home/franco/.ivy2/cache/com.twitter/chill_2.10/jars/chill_2.10-0.5.1.jar:/home/franco/.ivy2/cache/com.twitter/chill-java/jars/chill-java-0.5.1.jar:/home/franco/.ivy2/cache/com.esotericsoftware.kryo/kryo/bundles/kryo-2.21.jar:/home/franco/.ivy2/cache/com.esotericsoftware.reflectasm/reflectasm/jars/reflectasm-1.07-shaded.jar:/home/franco/.ivy2/cache/org.ow2.asm/asm/jars/asm-4.0.jar:/home/franco/.ivy2/cache/com.esotericsoftware.minlog/minlog/jars/minlog-1.2.jar:/home/franco/.ivy2/cache/org.objenesis/objenesis/jars/objenesis-1.2.jar:/home/franco/.ivy2/cache/com.twitter/chill-avro_2.10/jars/chill-avro_2.10-0.5.1.jar:/home/franco/.ivy2/cache/com.twitter/chill-bijection_2.10/jars/chill-bijection_2.10-0.5.1.jar:/home/franco/.ivy2/cache/org.apache.kafka/kafka_2.10/jars/kafka_2.10-0.8.2.2.jar:/home/franco/.ivy2/cache/org.apache.kafka/kafka-clients/jars/kafka-clients-0.8.2.2.jar:/home/franco/.ivy2/cache/org.slf4j/slf4j-api/jars/slf4j-api-1.7.6.jar:/home/franco/.ivy2/cache/org.xerial.snappy/snappy-java/bundles/snappy-java-1.1.1.7.jar:/home/franco/.ivy2/cache/net.jpountz.lz4/lz4/jars/lz4-1.2.0.jar:/home/franco/.ivy2/cache/com.yammer.metrics/metrics-core/jars/metrics-core-2.2.0.jar:/home/franco/.ivy2/cache/net.sf.jopt-simple/jopt-simple/jars/jopt-simple-3.2.jar:/home/franco/.ivy2/cache/org.apache.storm/storm-kafka/jars/storm-kafka-0.9.6.jar:/home/franco/.ivy2/cache/org.apache.curator/curator-framework/bundles/curator-framework-2.5.0.jar:/home/franco/.ivy2/cache/org.apache.curator/curator-client/bundles/curator-client-2.5.0.jar:/home/franco/.ivy2/cache/com.google.guava/guava/bundles/guava-16.0.1.jar:/home/franco/.ivy2/cache/org.apache.spark/spark-core_2.10/jars/spark-core_2.10-1.1.1.jar:/home/franco/.ivy2/cache/org.apache.hadoop/hadoop-client/jars/hadoop-client-1.0.4.jar:/home/franco/.ivy2/cache/org.apache.hadoop/hadoop-core/jars/hadoop-core-1.0.4.jar:/home/franco/.ivy2/cache/xmlenc/xmlenc/jars/xmlenc-0.52.jar:/home/franco/.ivy2/cache/commons-configuration/commons-configuration/jars/commons-configuration-1.6.jar:/home/franco/.ivy2/cache/commons-digester/commons-digester/jars/commons-digester-1.8.jar:/home/franco/.ivy2/cache/commons-beanutils/commons-beanutils/jars/commons-beanutils-1.7.0.jar:/home/franco/.ivy2/cache/commons-beanutils/commons-beanutils-core/jars/commons-beanutils-core-1.8.0.jar:/home/franco/.ivy2/cache/commons-net/commons-net/jars/commons-net-2.2.jar:/home/franco/.ivy2/cache/commons-el/commons-el/jars/commons-el-1.0.jar:/home/franco/.ivy2/cache/hsqldb/hsqldb/jars/hsqldb-1.8.0.10.jar:/home/franco/.ivy2/cache/oro/oro/jars/oro-2.0.8.jar:/home/franco/.ivy2/cache/net.java.dev.jets3t/jets3t/jars/jets3t-0.7.1.jar:/home/franco/.ivy2/cache/commons-httpclient/commons-httpclient/jars/commons-httpclient-3.1.jar:/home/franco/.ivy2/cache/org.apache.curator/curator-recipes/bundles/curator-recipes-2.4.0.jar:/home/franco/.ivy2/cache/org.eclipse.jetty/jetty-plus/jars/jetty-plus-8.1.14.v20131031.jar:/home/franco/.ivy2/cache/org.eclipse.jetty.orbit/javax.transaction/orbits/javax.transaction-1.1.1.v201105210645.jar:/home/franco/.ivy2/cache/org.eclipse.jetty/jetty-webapp/jars/jetty-webapp-8.1.14.v20131031.jar:/home/franco/.ivy2/cache/org.eclipse.jetty/jetty-xml/jars/jetty-xml-8.1.14.v20131031.jar:/home/franco/.ivy2/cache/org.eclipse.jetty/jetty-util/jars/jetty-util-8.1.14.v20131031.jar:/home/franco/.ivy2/cache/org.eclipse.jetty/jetty-servlet/jars/jetty-servlet-8.1.14.v20131031.jar:/home/franco/.ivy2/cache/org.eclipse.jetty/jetty-security/jars/jetty-security-8.1.14.v20131031.jar:/home/franco/.ivy2/cache/org.eclipse.jetty/jetty-server/jars/jetty-server-8.1.14.v20131031.jar:/home/franco/.ivy2/cache/org.eclipse.jetty.orbit/javax.servlet/orbits/javax.servlet-3.0.0.v201112011016.jar:/home/franco/.ivy2/cache/org.eclipse.jetty/jetty-continuation/jars/jetty-continuation-8.1.14.v20131031.jar:/home/franco/.ivy2/cache/org.eclipse.jetty/jetty-http/jars/jetty-http-8.1.14.v20131031.jar:/home/franco/.ivy2/cache/org.eclipse.jetty/jetty-io/jars/jetty-io-8.1.14.v20131031.jar:/home/franco/.ivy2/cache/org.eclipse.jetty/jetty-jndi/jars/jetty-jndi-8.1.14.v20131031.jar:/home/franco/.ivy2/cache/org.eclipse.jetty.orbit/javax.mail.glassfish/orbits/javax.mail.glassfish-1.4.1.v201005082020.jar:/home/franco/.ivy2/cache/org.eclipse.jetty.orbit/javax.activation/orbits/javax.activation-1.1.0.v201105071233.jar:/home/franco/.ivy2/cache/org.apache.commons/commons-lang3/jars/commons-lang3-3.3.2.jar:/home/franco/.ivy2/cache/com.google.code.findbugs/jsr305/jars/jsr305-1.3.9.jar:/home/franco/.ivy2/cache/com.ning/compress-lzf/bundles/compress-lzf-1.0.0.jar:/home/franco/.ivy2/cache/org.spark-project.akka/akka-remote_2.10/bundles/akka-remote_2.10-2.2.3-shaded-protobuf.jar:/home/franco/.ivy2/cache/org.spark-project.akka/akka-actor_2.10/jars/akka-actor_2.10-2.2.3-shaded-protobuf.jar:/home/franco/.ivy2/cache/com.typesafe/config/bundles/config-1.0.2.jar:/home/franco/.ivy2/cache/io.netty/netty/bundles/netty-3.6.6.Final.jar:/home/franco/.ivy2/cache/org.spark-project.protobuf/protobuf-java/jars/protobuf-java-2.4.1-shaded.jar:/home/franco/.ivy2/cache/org.uncommons.maths/uncommons-maths/jars/uncommons-maths-1.2.2a.jar:/home/franco/.ivy2/cache/org.spark-project.akka/akka-slf4j_2.10/bundles/akka-slf4j_2.10-2.2.3-shaded-protobuf.jar:/home/franco/.ivy2/cache/org.json4s/json4s-jackson_2.10/jars/json4s-jackson_2.10-3.2.10.jar:/home/franco/.ivy2/cache/org.json4s/json4s-core_2.10/jars/json4s-core_2.10-3.2.10.jar:/home/franco/.ivy2/cache/org.json4s/json4s-ast_2.10/jars/json4s-ast_2.10-3.2.10.jar:/home/franco/.ivy2/cache/com.thoughtworks.paranamer/paranamer/jars/paranamer-2.6.jar:/home/franco/.ivy2/cache/org.scala-lang/scalap/jars/scalap-2.10.4.jar:/home/franco/.sbt/boot/scala-2.10.4/lib/scala-compiler.jar:/home/franco/.ivy2/cache/com.fasterxml.jackson.core/jackson-databind/bundles/jackson-databind-2.3.1.jar:/home/franco/.ivy2/cache/com.fasterxml.jackson.core/jackson-annotations/bundles/jackson-annotations-2.3.0.jar:/home/franco/.ivy2/cache/com.fasterxml.jackson.core/jackson-core/bundles/jackson-core-2.3.1.jar:/home/franco/.ivy2/cache/colt/colt/jars/colt-1.2.0.jar:/home/franco/.ivy2/cache/concurrent/concurrent/jars/concurrent-1.3.4.jar:/home/franco/.ivy2/cache/org.apache.mesos/mesos/jars/mesos-0.18.1-shaded-protobuf.jar:/home/franco/.ivy2/cache/io.netty/netty-all/jars/netty-all-4.0.23.Final.jar:/home/franco/.ivy2/cache/com.clearspring.analytics/stream/jars/stream-2.7.0.jar:/home/franco/.ivy2/cache/com.codahale.metrics/metrics-core/bundles/metrics-core-3.0.0.jar:/home/franco/.ivy2/cache/com.codahale.metrics/metrics-jvm/bundles/metrics-jvm-3.0.0.jar:/home/franco/.ivy2/cache/com.codahale.metrics/metrics-json/bundles/metrics-json-3.0.0.jar:/home/franco/.ivy2/cache/com.codahale.metrics/metrics-graphite/bundles/metrics-graphite-3.0.0.jar:/home/franco/.ivy2/cache/org.tachyonproject/tachyon-client/jars/tachyon-client-0.5.0.jar:/home/franco/.ivy2/cache/org.tachyonproject/tachyon/jars/tachyon-0.5.0.jar:/home/franco/.ivy2/cache/commons-io/commons-io/jars/commons-io-2.4.jar:/home/franco/.ivy2/cache/org.spark-project/pyrolite/jars/pyrolite-2.0.1.jar:/home/franco/.ivy2/cache/net.sf.py4j/py4j/jars/py4j-0.8.2.1.jar:/home/franco/.ivy2/cache/org.apache.spark/spark-streaming-kafka_2.10/jars/spark-streaming-kafka_2.10-1.1.1.jar:/home/franco/.ivy2/cache/org.apache.spark/spark-streaming_2.10/jars/spark-streaming_2.10-1.1.1.jar:/home/franco/.ivy2/cache/com.101tec/zkclient/jars/zkclient-0.4.jar:/home/franco/.ivy2/cache/org.apache.curator/curator-test/jars/curator-test-2.4.0.jar:/home/franco/.ivy2/cache/org.javassist/javassist/jars/javassist-3.15.0-GA.jar:/home/franco/.ivy2/cache/org.apache.commons/commons-math/jars/commons-math-2.2.jar:/home/franco/.ivy2/cache/org.apache.zookeeper/zookeeper/jars/zookeeper-3.4.5.jar:/home/franco/.ivy2/cache/log4j/log4j/jars/log4j-1.2.15.jar:/home/franco/.ivy2/cache/javax.mail/mail/jars/mail-1.4.jar:/home/franco/.ivy2/cache/javax.activation/activation/jars/activation-1.1.jar:/home/franco/.ivy2/cache/org.apache.commons/commons-pool2/jars/commons-pool2-2.3.jar:/home/franco/.ivy2/cache/ch.qos.logback/logback-classic/jars/logback-classic-1.1.2.jar:/home/franco/.ivy2/cache/ch.qos.logback/logback-core/jars/logback-core-1.1.2.jar:/home/franco/.ivy2/cache/org.scala-lang/scala-reflect/jars/scala-reflect-2.10.5.jar:/home/franco/.ivy2/cache/org.scalatest/scalatest_2.10/bundles/scalatest_2.10-2.2.4.jar:/home/franco/.ivy2/cache/org.mockito/mockito-all/jars/mockito-all-1.9.5.jar:/home/franco/.ivy2/cache/org.apache.storm/storm-core/jars/storm-core-0.9.6.jar:/home/franco/.ivy2/cache/org.clojure/clojure/jars/clojure-1.5.1.jar:/home/franco/.ivy2/cache/clj-time/clj-time/jars/clj-time-0.4.1.jar:/home/franco/.ivy2/cache/joda-time/joda-time/jars/joda-time-2.0.jar:/home/franco/.ivy2/cache/compojure/compojure/jars/compojure-1.1.3.jar:/home/franco/.ivy2/cache/org.clojure/core.incubator/jars/core.incubator-0.1.0.jar:/home/franco/.ivy2/cache/org.clojure/tools.macro/jars/tools.macro-0.1.0.jar:/home/franco/.ivy2/cache/clout/clout/jars/clout-1.0.1.jar:/home/franco/.ivy2/cache/ring/ring-core/jars/ring-core-1.1.5.jar:/home/franco/.ivy2/cache/commons-codec/commons-codec/jars/commons-codec-1.6.jar:/home/franco/.ivy2/cache/commons-fileupload/commons-fileupload/jars/commons-fileupload-1.2.1.jar:/home/franco/.ivy2/cache/javax.servlet/servlet-api/jars/servlet-api-2.5.jar:/home/franco/.ivy2/cache/hiccup/hiccup/jars/hiccup-0.3.6.jar:/home/franco/.ivy2/cache/ring/ring-devel/jars/ring-devel-0.3.11.jar:/home/franco/.ivy2/cache/clj-stacktrace/clj-stacktrace/jars/clj-stacktrace-0.2.2.jar:/home/franco/.ivy2/cache/ring/ring-jetty-adapter/jars/ring-jetty-adapter-0.3.11.jar:/home/franco/.ivy2/cache/ring/ring-servlet/jars/ring-servlet-0.3.11.jar:/home/franco/.ivy2/cache/org.mortbay.jetty/jetty/jars/jetty-6.1.26.jar:/home/franco/.ivy2/cache/org.mortbay.jetty/jetty-util/jars/jetty-util-6.1.26.jar:/home/franco/.ivy2/cache/org.mortbay.jetty/servlet-api/jars/servlet-api-2.5-20081211.jar:/home/franco/.ivy2/cache/org.clojure/tools.logging/jars/tools.logging-0.2.3.jar:/home/franco/.ivy2/cache/org.clojure/math.numeric-tower/jars/math.numeric-tower-0.0.1.jar:/home/franco/.ivy2/cache/org.clojure/tools.cli/jars/tools.cli-0.2.4.jar:/home/franco/.ivy2/cache/org.apache.commons/commons-exec/jars/commons-exec-1.1.jar:/home/franco/.ivy2/cache/com.googlecode.json-simple/json-simple/jars/json-simple-1.1.jar:/home/franco/.ivy2/cache/com.twitter/carbonite/jars/carbonite-1.4.0.jar:/home/franco/.ivy2/cache/org.yaml/snakeyaml/bundles/snakeyaml-1.11.jar:/home/franco/.ivy2/cache/commons-logging/commons-logging/jars/commons-logging-1.1.3.jar:/home/franco/.ivy2/cache/com.googlecode.disruptor/disruptor/jars/disruptor-2.10.4.jar:/home/franco/.ivy2/cache/org.jgrapht/jgrapht-core/jars/jgrapht-core-0.9.0.jar:/home/franco/.ivy2/cache/jline/jline/jars/jline-2.11.jar -Ywarn-nullary-unit -deprecation -feature -Xlint -Ywarn-inaccessible -Ywarn-nullary-override -bootclasspath /usr/lib/jvm/java-8-oracle/jre/lib/resources.jar:/usr/lib/jvm/java-8-oracle/jre/lib/rt.jar:/usr/lib/jvm/java-8-oracle/jre/lib/sunrsasign.jar:/usr/lib/jvm/java-8-oracle/jre/lib/jsse.jar:/usr/lib/jvm/java-8-oracle/jre/lib/jce.jar:/usr/lib/jvm/java-8-oracle/jre/lib/charsets.jar:/usr/lib/jvm/java-8-oracle/jre/lib/jfr.jar:/usr/lib/jvm/java-8-oracle/jre/classes:/home/franco/.ivy2/cache/org.scala-lang/scala-library/jars/scala-library-2.10.5.jar -unchecked -Ywarn-adapted-args -target:jvm-1.7
[error] 
[error]   last tree to typer: Literal(Constant(com.miguno.avro.Tweet))
[error]               symbol: null
[error]    symbol definition: null
[error]                  tpe: Class(classOf[com.miguno.avro.Tweet])
[error]        symbol owners: 
[error]       context owners: anonymous class anonfun$createAndStartConsumer$1 -> package testing
[error] 
[error] == Enclosing template or block ==
[error] 
[error] Template( // val <local $anonfun>: <notype>, tree.tpe=com.miguno.kafkastorm.testing.anonfun$createAndStartConsumer$1
[error]   "scala.runtime.AbstractFunction3", "scala.Serializable" // parents
[error]   ValDef(
[error]     private
[error]     "_"
[error]     <tpt>
[error]     <empty>
[error]   )
[error]   // 4 statements
[error]   DefDef( // final def apply(m: kafka.message.MessageAndMetadata,c: com.miguno.kafkastorm.kafka.ConsumerTaskContext,n: Option): Unit
[error]     <method> final <triedcooking>
[error]     "apply"
[error]     []
[error]     // 1 parameter list
[error]     ValDef( // m: kafka.message.MessageAndMetadata
[error]       <param> <triedcooking>
[error]       "m"
[error]       <tpt> // tree.tpe=kafka.message.MessageAndMetadata
[error]       <empty>
[error]     )
[error]     ValDef( // c: com.miguno.kafkastorm.kafka.ConsumerTaskContext
[error]       <param> <triedcooking>
[error]       "c"
[error]       <tpt> // tree.tpe=com.miguno.kafkastorm.kafka.ConsumerTaskContext
[error]       <empty>
[error]     )
[error]     ValDef( // n: Option
[error]       <param>
[error]       "n"
[error]       <tpt> // tree.tpe=Option
[error]       <empty>
[error]     )
[error]     <tpt> // tree.tpe=Unit
[error]     Block( // tree.tpe=Unit
[error]       Apply( // def apply(v1: Object,v2: Object): Object in trait Function2, tree.tpe=Object
[error]         EmbeddedKafkaZooKeeperCluster$$anonfun$createAndStartConsumer$1.this."consume$1"."apply" // def apply(v1: Object,v2: Object): Object in trait Function2, tree.tpe=(v1: Object, v2: Object)Object
[error]         // 2 arguments
[error]         "m" // m: kafka.message.MessageAndMetadata, tree.tpe=kafka.message.MessageAndMetadata
[error]         "c" // c: com.miguno.kafkastorm.kafka.ConsumerTaskContext, tree.tpe=com.miguno.kafkastorm.kafka.ConsumerTaskContext
[error]       )
[error]       ()
[error]     )
[error]   )
[error]   DefDef( // final def apply(v1: Object,v2: Object,v3: Object): Object
[error]     <method> final <bridge>
[error]     "apply"
[error]     []
[error]     // 1 parameter list
[error]     ValDef( // v1: Object
[error]       <param> <triedcooking>
[error]       "v1"
[error]       <tpt> // tree.tpe=Object
[error]       <empty>
[error]     )
[error]     ValDef( // v2: Object
[error]       <param> <triedcooking>
[error]       "v2"
[error]       <tpt> // tree.tpe=Object
[error]       <empty>
[error]     )
[error]     ValDef( // v3: Object
[error]       <param> <triedcooking>
[error]       "v3"
[error]       <tpt> // tree.tpe=Object
[error]       <empty>
[error]     )
[error]     <tpt> // tree.tpe=Object
[error]     Block( // tree.tpe=runtime.BoxedUnit
[error]       Apply( // final def apply(m: kafka.message.MessageAndMetadata,c: com.miguno.kafkastorm.kafka.ConsumerTaskContext,n: Option): Unit, tree.tpe=Unit
[error]         EmbeddedKafkaZooKeeperCluster$$anonfun$createAndStartConsumer$1.this."apply" // final def apply(m: kafka.message.MessageAndMetadata,c: com.miguno.kafkastorm.kafka.ConsumerTaskContext,n: Option): Unit, tree.tpe=(m: kafka.message.MessageAndMetadata, c: com.miguno.kafkastorm.kafka.ConsumerTaskContext, n: Option)Unit
[error]         // 3 arguments
[error]         Apply( // final def $asInstanceOf[T0 >: ? <: ?](): T0 in class Object, tree.tpe=kafka.message.MessageAndMetadata
[error]           TypeApply( // final def $asInstanceOf[T0 >: ? <: ?](): T0 in class Object, tree.tpe=()kafka.message.MessageAndMetadata
[error]             "v1"."$asInstanceOf" // final def $asInstanceOf[T0 >: ? <: ?](): T0 in class Object, tree.tpe=[T0 >: ? <: ?]()T0
[error]             <tpt> // tree.tpe=kafka.message.MessageAndMetadata
[error]           )
[error]           Nil
[error]         )
[error]         Apply( // final def $asInstanceOf[T0 >: ? <: ?](): T0 in class Object, tree.tpe=com.miguno.kafkastorm.kafka.ConsumerTaskContext
[error]           TypeApply( // final def $asInstanceOf[T0 >: ? <: ?](): T0 in class Object, tree.tpe=()com.miguno.kafkastorm.kafka.ConsumerTaskContext
[error]             "v2"."$asInstanceOf" // final def $asInstanceOf[T0 >: ? <: ?](): T0 in class Object, tree.tpe=[T0 >: ? <: ?]()T0
[error]             <tpt> // tree.tpe=com.miguno.kafkastorm.kafka.ConsumerTaskContext
[error]           )
[error]           Nil
[error]         )
[error]         Apply( // final def $asInstanceOf[T0 >: ? <: ?](): T0 in class Object, tree.tpe=Option
[error]           TypeApply( // final def $asInstanceOf[T0 >: ? <: ?](): T0 in class Object, tree.tpe=()Option
[error]             "v3"."$asInstanceOf" // final def $asInstanceOf[T0 >: ? <: ?](): T0 in class Object, tree.tpe=[T0 >: ? <: ?]()T0
[error]             <tpt> // tree.tpe=Option
[error]           )
[error]           Nil
[error]         )
[error]       )
[error]       "scala"."runtime"."BoxedUnit"."UNIT" // final val UNIT: runtime.BoxedUnit in object BoxedUnit, tree.tpe=runtime.BoxedUnit
[error]     )
[error]   )
[error]   ValDef( // private[this] val consume$1: Function2
[error]     private <local> <synthetic> <paramaccessor> <triedcooking>
[error]     "consume$1"
[error]     <tpt> // tree.tpe=Function2
[error]     <empty>
[error]   )
[error]   DefDef( // def <init>(arg$outer: com.miguno.kafkastorm.testing.EmbeddedKafkaZooKeeperCluster,consume$1: Function2): com.miguno.kafkastorm.testing.anonfun$createAndStartConsumer$1
[error]     <method> <triedcooking>
[error]     "<init>"
[error]     []
[error]     // 1 parameter list
[error]     ValDef( // $outer: com.miguno.kafkastorm.testing.EmbeddedKafkaZooKeeperCluster
[error]       <param>
[error]       "$outer"
[error]       <tpt> // tree.tpe=com.miguno.kafkastorm.testing.EmbeddedKafkaZooKeeperCluster
[error]       <empty>
[error]     )
[error]     ValDef( // consume$1: Function2
[error]       <param> <synthetic> <triedcooking>
[error]       "consume$1"
[error]       <tpt> // tree.tpe=Function2
[error]       <empty>
[error]     )
[error]     <tpt> // tree.tpe=com.miguno.kafkastorm.testing.anonfun$createAndStartConsumer$1
[error]     Block( // tree.tpe=Unit
[error]       // 2 statements
[error]       Assign( // tree.tpe=Unit
[error]         EmbeddedKafkaZooKeeperCluster$$anonfun$createAndStartConsumer$1.this."consume$1" // private[this] val consume$1: Function2, tree.tpe=Function2
[error]         "consume$1" // consume$1: Function2, tree.tpe=Function2
[error]       )
[error]       Apply( // def <init>(): scala.runtime.AbstractFunction3 in class AbstractFunction3, tree.tpe=scala.runtime.AbstractFunction3
[error]         EmbeddedKafkaZooKeeperCluster$$anonfun$createAndStartConsumer$1.super."<init>" // def <init>(): scala.runtime.AbstractFunction3 in class AbstractFunction3, tree.tpe=()scala.runtime.AbstractFunction3
[error]         Nil
[error]       )
[error]       ()
[error]     )
[error]   )
[error] )
[error] 
[error] == Expanded type of tree ==
[error] 
[error] ConstantType(value = Constant(com.miguno.avro.Tweet))
[error] 
[error] uncaught exception during compilation: java.io.IOException
[error] File name too long
[error] two errors found
[error] (test:compile) Compilation failed
[error] Total time: 9 s, completed Sep 1, 2016 9:00:17 AM
miguno commented 8 years ago

Hmm, what stands out is:

[error] uncaught exception during compilation: java.io.IOException
[error] File name too long

Perhaps an issue with your local filesystem?

francotestori commented 8 years ago

Indeed, the problem was with ubuntu's encrypted filesystem. Thanks for the guidance.

miguno commented 8 years ago

Sure, happy it works now.