Re: java.lang.NoClassDefFoundError, is this a bug?

2016-09-17 Thread Xiang Gao
Yes. Besides, if you change the "T : Encoder" to "T", it OK too. -- View this message in context: http://apache-spark-developers-list.1001551.n3.nabble.com/java-lang-NoClassDefFoundError-is-this-a-bug-tp18972p18981.html Sent from the Apache Spark Developers List mailing list archive at

Re: java.lang.NoClassDefFoundError, is this a bug?

2016-09-17 Thread WangJianfei
if I remove this abstract class A[T : Encoder] {} it's ok! -- View this message in context: http://apache-spark-developers-list.1001551.n3.nabble.com/java-lang-NoClassDefFoundError-is-this-a-bug-tp18972p18980.html Sent from the Apache Spark Developers List mailing list archive at Nabble.com.

Re: java.lang.NoClassDefFoundError, is this a bug?

2016-09-17 Thread Xiang Gao
spark standalone cluster -- View this message in context: http://apache-spark-developers-list.1001551.n3.nabble.com/java-lang-NoClassDefFoundError-is-this-a-bug-tp18972p18979.html Sent from the Apache Spark Developers List mailing list archive at Nabble.com.

Re: java.lang.NoClassDefFoundError, is this a bug?

2016-09-17 Thread WangJianfei
do you run this on yarn mode or else? -- View this message in context: http://apache-spark-developers-list.1001551.n3.nabble.com/java-lang-NoClassDefFoundError-is-this-a-bug-tp18972p18978.html Sent from the Apache Spark Developers List mailing list archive at Nabble.com.

Re: Fwd: Question regarding merging to two RDDs

2016-09-17 Thread WangJianfei
maybe you can use dataframe ,with the header file as a schema -- View this message in context: http://apache-spark-developers-list.1001551.n3.nabble.com/Fwd-Question-regarding-merging-to-two-RDDs-tp18971p18977.html Sent from the Apache Spark Developers List mailing list archive at Nabble.com.

Re: java.lang.NoClassDefFoundError, is this a bug?

2016-09-17 Thread Xiang Gao
Besides, if you replace line #14 with: Env.spark.createDataset(Seq("a","b","c")).rdd.map(func).collect() You will have the same problem with a different stack trace: Caused by: java.lang.NoClassDefFoundError: Could not initialize class Main$ at Main$$anonfun$main$1.apply(test.scala:14)

Re: java.lang.NoClassDefFoundError, is this a bug?

2016-09-17 Thread Jacek Laskowski
Hi, I'm surprised too. Here's the entire stack trace for reference. I'd also like to know what causes the issue. Caused by: java.lang.NoClassDefFoundError: Could not initialize class Main$ at Main$$anonfun$main$1.apply(test.scala:14) at Main$$anonfun$main$1.apply(test.scala:14) at

Re: Different versions of dependencies in assembly/target/scala-2.11/jars?

2016-09-17 Thread Jacek Laskowski
Hi Sean, Thanks a lot for help understanding the different jars. Do you think there's anything that should be reported as an enhancement/issue/task in JIRA? Pozdrawiam, Jacek Laskowski https://medium.com/@jaceklaskowski/ Mastering Apache Spark 2.0 http://bit.ly/mastering-apache-spark

Re: Different versions of dependencies in assembly/target/scala-2.11/jars?

2016-09-17 Thread Sean Owen
No, these are different major versions of these components, each of which gets used by something in the transitive dependency graph. They are not redundant because they're not actually presenting roughly the same component in the same namespace. However the parquet-hadoop bit looks wrong, in that

java.lang.NoClassDefFoundError, is this a bug?

2016-09-17 Thread Xiang Gao
Hi, In my application, I got a weird error message: java.lang.NoClassDefFoundError: Could not initialize class X This happens only when I try to submit my application in cluster mode. It works perfectly in client mode. I'm able to reproduce this error message by a simple 16-line program:

Fwd: Question regarding merging to two RDDs

2016-09-17 Thread Hiral Mehta
Hi, I have two separate csv files one with header and other with data. I read those two files in 2 different RDDs and now I need to merge both the RDDs. I tried various options such as union, zip, join but none worked for my problem. What is the best way to merge two RDDs so that the header and

Different versions of dependencies in assembly/target/scala-2.11/jars?

2016-09-17 Thread Jacek Laskowski
Hi, Just noticed in assembly/target/scala-2.11/jars that similar libraries have different versions: -rw-r--r-- 1 jacek staff 1230201 17 wrz 09:51 netty-3.8.0.Final.jar -rw-r--r-- 1 jacek staff 2305335 17 wrz 09:51 netty-all-4.0.41.Final.jar and -rw-r--r-- 1 jacek staff218076 17