Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Spark 1.2 #294

Merged
merged 4 commits into from Feb 12, 2015
Merged

Spark 1.2 #294

merged 4 commits into from Feb 12, 2015

Conversation

Leemoonsoo
Copy link
Contributor

Trying to Zeppelin work with Spark 1.2

How to test this branch

  1. Build and install spark artifact locally (for spark-repl.jar)

Because of spark-repl artifact is not yet released for 1.2 version, need to build and deploy locally, before build Zeppelin.
To do that, clone spark 1.2 source and run

sbt/sbt publish-local
  1. Checkout this spark_1.2 branch and build Zeppelin with spark-1.2 profile
mvn -DskipTests -Pspark-1.2 package

Here's simple test i did in local mode.

image

@tribbloid
Copy link

Don't worry, they are just slow.
http://mvnrepository.com/artifact/org.apache.spark/spark-repl_2.10 is still empty

@felixcheung
Copy link
Contributor

(update: I got it...) from the spark source https://github.com/apache/spark/commits/branch-1.2? It doesn't seem like SPARK-4923 is ported to Spark branch-1.2 yet apache/spark@d05c9ee
so I think this should be building from Spark master

@felixcheung
Copy link
Contributor

I couldn't get maven to look at the publish by sbt. is there a way to do that?

@Leemoonsoo
Copy link
Contributor Author

What i did is

git clone -b v1.2.0 https://github.com/apache/spark.git
cd spark
sbt/sbt publish-local

I think spark 1.2.0 supposed to skip publish spark-repl artifact to public maven repository until SPARK-4923 resolved, but i think it does still deploy spark-repl to local m2 repository.

@felixcheung
Copy link
Contributor

Thanks, that works after a clean.

I'm getting this build error. any idea?
[ERROR] Failed to execute goal com.github.eirslett:frontend-maven-plugin:0.0.16:npm (npm install) on project zeppelin-web: Failed to run task: 'npm install --color=false' failed. (error code 1) -> [Help 1]

[INFO] --- frontend-maven-plugin:0.0.16:install-node-and-npm (install node and npm) @ zeppelin-web ---
[INFO] Node v0.10.18 is already installed.
[INFO] Found NPM version 1.3.8
[INFO]
[INFO] --- frontend-maven-plugin:0.0.16:npm (npm install ansi-color) @ zeppelin-web ---
[INFO] Running 'npm install http://registry.npmjs.org/ansi-color/-/ansi-color-0.2.1.tgz --color=false' in /Users////zeppelin/zeppelin-web
[INFO] npm WARN package.json zeppelin-web@0.0.0 No repository field.
[INFO] npm WARN package.json ansi-color@0.2.1 'repositories' (plural) Not supported.
[INFO] npm WARN package.json Please pick one as the 'repository' field
[INFO] npm http GET http://registry.npmjs.org/ansi-color/-/ansi-color-0.2.1.tgz
[INFO] npm http 200 http://registry.npmjs.org/ansi-color/-/ansi-color-0.2.1.tgz
[INFO] ansi-color@0.2.1 node_modules/ansi-color
[INFO]
[INFO] --- frontend-maven-plugin:0.0.16:npm (npm install) @ zeppelin-web ---
[INFO] Running 'npm install --color=false' in /Users////zeppelin/zeppelin-web
[INFO] npm WARN package.json zeppelin-web@0.0.0 No repository field.
[INFO] npm WARN package.json ansi-color@0.2.1 'repositories' (plural) Not supported.
[INFO] npm WARN package.json Please pick one as the 'repository' field
[INFO]
[INFO] > zeppelin-web@0.0.0 postinstall /Users////zeppelin/zeppelin-web
[INFO] > ./node_modules/bower/bin/bower --allow-root install

@anthonycorbacho
Copy link
Contributor

@felixcheung , About the build error on Zeppelin-web, I am working on a fix ( PR #296 ). I guess it will be ready really soon.

@felixcheung
Copy link
Contributor

I merged with your branch in that PR and now I'm seeing this:

[INFO] bower angular#1.3.8 cached git://github.com/angular/bower-angular.git#1.3.8
[INFO] bower angular#1.3.8 validate 1.3.8 against git://github.com/angular/bower-angular.git#1.3.8
[INFO] bower ECONFLICT Unable to find suitable version for angular

ERROR] Failed to execute goal com.github.eirslett:frontend-maven-plugin:0.0.20:bower (bower install) on project zeppelin-web: Failed to run task: 'bower --allow-root install' failed. (error code 1) -> [Help 1]

@felixcheung
Copy link
Contributor

I'm building with
mvn -DskipTests -Pspark-1.2 clean package

Really trying to get that to work :)

@corneadoug
Copy link
Contributor

@felixcheung Did you delete bower_components and node_modules folders before compiling?
Since anthony's branch brings change in the packages and is also not downloading packages if they exist in the cache, it might be good to try it with clean cache

@Leemoonsoo
Copy link
Contributor Author

rm -rf zeppelin-web/bower_components might help.

@anthonycorbacho
Copy link
Contributor

Well just to be sure

./bower cache clean
rm -rf zeppelin-web/bower_components zeppelin-web/node zeppelin-web/node_modules

@felixcheung
Copy link
Contributor

It works! thanks for jumping in to help

[INFO] Zeppelin ........................................... SUCCESS [ 4.857 s]
[INFO] Zeppelin: Zengine .................................. SUCCESS [ 10.218 s]
[INFO] Zeppelin: Spark .................................... SUCCESS [ 8.583 s]
[INFO] Zeppelin: Markdown interpreter ..................... SUCCESS [ 1.796 s]
[INFO] Zeppelin: Shell interpreter ........................ SUCCESS [ 1.797 s]
[INFO] Zeppelin: web Application .......................... SUCCESS [03:09 min]
[INFO] Zeppelin: Server ................................... SUCCESS [ 16.648 s]
[INFO] Zeppelin: Packaging distribution ................... SUCCESS [ 0.368 s]

@anthonycorbacho
Copy link
Contributor

Glad to see thats finally worked!
Happy Zeppelin!!

@jongyoul
Copy link
Contributor

When this PR merge to master?

@tribbloid
Copy link

I think after spark-repl 1.3.0 (or at least 1.2.1) is released?

On 01/29/2015 07:11 PM, Jongyoul Lee wrote:

When this PR merge to |master|?


Reply to this email directly or view it on GitHub
#294 (comment).

@jongyoul
Copy link
Contributor

I agree that It's a little difficult to build it. How about setting spark 1.2 as an option? Default setting is 1.1 and 1.2 is just an option. While master changes so fast, but because I'm using spark 1.2, I cannot use new feature.

@felixcheung
Copy link
Contributor

This might be a separate topic but I couldn't get Spark 1.2 profile to work with MASTER=yarn-client.

From the exception below it seems to indicate the class cannot be loaded, but this class should be in spark-core. The spark jars are in zeppelin/interpreter/spark and I couldn't get it to load from somewhere else (I've set SPARK_HOME to /usr/lib/spark)

Any idea?

------ Create new SparkContext yarn-client -------
java.lang.ExceptionInInitializerError
at org.apache.spark.util.Utils$.getSparkOrYarnConfig(Utils.scala:1784)
at org.apache.spark.storage.BlockManager.(BlockManager.scala:105)
at org.apache.spark.storage.BlockManager.(BlockManager.scala:180)
at org.apache.spark.SparkEnv$.create(SparkEnv.scala:292)
at org.apache.spark.SparkEnv$.createDriverEnv(SparkEnv.scala:159)
at org.apache.spark.SparkContext.(SparkContext.scala:232)
at com.nflabs.zeppelin.spark.SparkInterpreter.createSparkContext(SparkInterpreter.java:151)
at com.nflabs.zeppelin.spark.SparkInterpreter.getSparkContext(SparkInterpreter.java:102)
at com.nflabs.zeppelin.spark.SparkInterpreter.open(SparkInterpreter.java:243)
at com.nflabs.zeppelin.interpreter.ClassloaderInterpreter.open(ClassloaderInterpreter.java:83)
at com.nflabs.zeppelin.interpreter.LazyOpenInterpreter.open(LazyOpenInterpreter.java:52)
at com.nflabs.zeppelin.interpreter.LazyOpenInterpreter.bindValue(LazyOpenInterpreter.java:88)
at com.nflabs.zeppelin.notebook.Paragraph.jobRun(Paragraph.java:175)
at com.nflabs.zeppelin.scheduler.Job.run(Job.java:147)
at com.nflabs.zeppelin.scheduler.FIFOScheduler$1.run(FIFOScheduler.java:85)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:178)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:292)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: org.apache.spark.SparkException: Unable to load YARN support
at org.apache.spark.deploy.SparkHadoopUtil$.liftedTree1$1(SparkHadoopUtil.scala:199)
at org.apache.spark.deploy.SparkHadoopUtil$.(SparkHadoopUtil.scala:194)
at org.apache.spark.deploy.SparkHadoopUtil$.(SparkHadoopUtil.scala)
... 22 more
Caused by: java.lang.ClassNotFoundException: org.apache.spark.deploy.yarn.YarnSparkHadoopUtil
at java.net.URLClassLoader$1.run(URLClassLoader.java:366)
at java.net.URLClassLoader$1.run(URLClassLoader.java:355)
at java.security.AccessController.doPrivileged(Native Method)
at java.net.URLClassLoader.findClass(URLClassLoader.java:354)
at java.lang.ClassLoader.loadClass(ClassLoader.java:425)
at java.lang.ClassLoader.loadClass(ClassLoader.java:358)
at java.lang.Class.forName0(Native Method)
at java.lang.Class.forName(Class.java:190)
at org.apache.spark.deploy.SparkHadoopUtil$.liftedTree1$1(SparkHadoopUtil.scala:195)
... 24 more
------ Create new SparkContext yarn-client -------
Exception in thread "Thread-19" java.lang.NoClassDefFoundError: Could not initialize class org.apache.spark.deploy.SparkHadoopUtil$
at org.apache.spark.util.Utils$.getSparkOrYarnConfig(Utils.scala:1784)
at org.apache.spark.storage.BlockManager.(BlockManager.scala:105)
at org.apache.spark.storage.BlockManager.(BlockManager.scala:180)
at org.apache.spark.SparkEnv$.create(SparkEnv.scala:292)
at org.apache.spark.SparkEnv$.createDriverEnv(SparkEnv.scala:159)
at org.apache.spark.SparkContext.(SparkContext.scala:232)
at com.nflabs.zeppelin.spark.SparkInterpreter.createSparkContext(SparkInterpreter.java:151)
at com.nflabs.zeppelin.spark.SparkInterpreter.getSparkContext(SparkInterpreter.java:102)
at com.nflabs.zeppelin.spark.SparkInterpreter.open(SparkInterpreter.java:243)
at com.nflabs.zeppelin.interpreter.ClassloaderInterpreter.open(ClassloaderInterpreter.java:83)
at com.nflabs.zeppelin.interpreter.LazyOpenInterpreter.open(LazyOpenInterpreter.java:52)
at com.nflabs.zeppelin.interpreter.LazyOpenInterpreter.getProgress(LazyOpenInterpreter.java:99)
at com.nflabs.zeppelin.notebook.Paragraph.progress(Paragraph.java:150)
at com.nflabs.zeppelin.scheduler.JobProgressPoller.run(JobProgressPoller.java:35)

@jongyoul
Copy link
Contributor

@felixcheung You'd better set /path/to/hadoop/conf/dir to CLASSPATH.

CLASSPATH=/path/to/hadoop/conf ./zeppelin-daemon.sh start

@felixcheung
Copy link
Contributor

@jongyoul thanks, shouldn't class path be pointing to lib path instead of conf?

@jongyoul
Copy link
Contributor

If you set CLASSPATH before you start Zeppelin, It's included by java.lib.path. I don't think it's best way to include hadoop classpath but we don't have any other way to do this. I hope we can set HADOOP_CONF_DIR as well.

@felixcheung
Copy link
Contributor

Thanks, but unfortunately it didn't work:

$ CLASSPATH=/etc/hadoop/conf ./zeppelin-0.5.0-SNAPSHOT/bin/zeppelin-daemon.sh start
Zeppelin start [ OK ]
$ ls /etc/hadoop/conf
core-site.xml hadoop-metrics.properties log4j.properties README
hadoop-env.sh hdfs-site.xml mapred-site.xml yarn-site.xml

Exception in thread "Thread-18" java.lang.NoClassDefFoundError: Could not initialize class org.apache.spark.deploy.SparkHadoopUtil$
at org.apache.spark.util.Utils$.getSparkOrYarnConfig(Utils.scala:1784)
at org.apache.spark.storage.BlockManager.(BlockManager.scala:105)
at org.apache.spark.storage.BlockManager.(BlockManager.scala:180)
at org.apache.spark.SparkEnv$.create(SparkEnv.scala:292)
at org.apache.spark.SparkEnv$.createDriverEnv(SparkEnv.scala:159)
at org.apache.spark.SparkContext.(SparkContext.scala:232)
at com.nflabs.zeppelin.spark.SparkInterpreter.createSparkContext(SparkInterpreter.java:151)
at com.nflabs.zeppelin.spark.SparkInterpreter.getSparkContext(SparkInterpreter.java:102)
at com.nflabs.zeppelin.spark.SparkInterpreter.open(SparkInterpreter.java:243)
at com.nflabs.zeppelin.interpreter.ClassloaderInterpreter.open(ClassloaderInterpreter.java:83)
at com.nflabs.zeppelin.interpreter.LazyOpenInterpreter.open(LazyOpenInterpreter.java:52)
at com.nflabs.zeppelin.interpreter.LazyOpenInterpreter.getProgress(LazyOpenInterpreter.java:99)
at com.nflabs.zeppelin.notebook.Paragraph.progress(Paragraph.java:150)
at com.nflabs.zeppelin.scheduler.JobProgressPoller.run(JobProgressPoller.java:35)

@jongyoul
Copy link
Contributor

jongyoul commented Feb 2, 2015

@felixcheung Yes, you're right. I've tested with those argument, and same error occurs. I've added spark-yarn package, but I also met another error. I'll do another thing

@swkimme
Copy link
Contributor

swkimme commented Feb 4, 2015

I think it's good to merge this PR, while maintaining spark 1.1 as a default and spark 1.2 as option,
as @jongyoul said.
It would be better if we add some document on this.

@kmader
Copy link

kmader commented Feb 5, 2015

An easier solution is to follow these instructions (and / or use the precompiled binary) https://gist.github.com/kmader/3394153de1154cb18475

@gtinside
Copy link

gtinside commented Feb 9, 2015

Still not working , I am doing
mvn -X -DskipTests -Pspark-1.2 package , getting following error :

[ERROR] Failed to execute goal org.codehaus.mojo:exec-maven-plugin:1.2.1:exec (grunt-build-to-src-main-webapp) on project zeppelin-web: Command execution failed. Process exited with an error: 6 (Exit value: 6) -> [Help 1]
org.apache.maven.lifecycle.LifecycleExecutionException: Failed to execute goal org.codehaus.mojo:exec-maven-plugin:1.2.1:exec (grunt-build-to-src-main-webapp) on project zeppelin-web: Command execution failed.
at org.apache.maven.lifecycle.internal.MojoExecutor.execute(MojoExecutor.java:216)
at org.apache.maven.lifecycle.internal.MojoExecutor.execute(MojoExecutor.java:153)
at org.apache.maven.lifecycle.internal.MojoExecutor.execute(MojoExecutor.java:145)
at org.apache.maven.lifecycle.internal.LifecycleModuleBuilder.buildProject(LifecycleModuleBuilder.java:116)
at org.apache.maven.lifecycle.internal.LifecycleModuleBuilder.buildProject(LifecycleModuleBuilder.java:80)
at org.apache.maven.lifecycle.internal.builder.singlethreaded.SingleThreadedBuilder.build(SingleThreadedBuilder.java:51)
at org.apache.maven.lifecycle.internal.LifecycleStarter.execute(LifecycleStarter.java:120)
at org.apache.maven.DefaultMaven.doExecute(DefaultMaven.java:347)
at org.apache.maven.DefaultMaven.execute(DefaultMaven.java:154)
at org.apache.maven.cli.MavenCli.execute(MavenCli.java:582)
at org.apache.maven.cli.MavenCli.doMain(MavenCli.java:214)
at org.apache.maven.cli.MavenCli.main(MavenCli.java:158)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:601)
at org.codehaus.plexus.classworlds.launcher.Launcher.launchEnhanced(Launcher.java:289)
at org.codehaus.plexus.classworlds.launcher.Launcher.launch(Launcher.java:229)
at org.codehaus.plexus.classworlds.launcher.Launcher.mainWithExitCode(Launcher.java:415)
at org.codehaus.plexus.classworlds.launcher.Launcher.main(Launcher.java:356)
Caused by: org.apache.maven.plugin.MojoExecutionException: Command execution failed.
at org.codehaus.mojo.exec.ExecMojo.execute(ExecMojo.java:362)
at org.apache.maven.plugin.DefaultBuildPluginManager.executeMojo(DefaultBuildPluginManager.java:132)
at org.apache.maven.lifecycle.internal.MojoExecutor.execute(MojoExecutor.java:208)
... 19 more

@ayoub-benali
Copy link

Spark repl 1.2.1 is now available in maven central so I guess everyone should be able to build zeppeling against spark 1.2.X

@swkimme
Copy link
Contributor

swkimme commented Feb 9, 2015

@ayoub-benali OMG, thanks for sharing.
@Leemoonsoo Let's go for Spark 1.2!

@tribbloid
Copy link

Good! late but still good :)

On 02/09/2015 11:01 AM, Kevin (Sangwoo) Kim wrote:

@ayoub-benali https://github.com/ayoub-benali OMG, thanks for sharing.
@Leemoonsoo https://github.com/Leemoonsoo Let's go for Spark 1.2!


Reply to this email directly or view it on GitHub
#294 (comment).

@felixcheung
Copy link
Contributor

They don't have it for 1.2.0. The plan was to back port it, I guess that hasn't been completed yet. I'm on 1.2.0 and can't move to 1.2.1 easily.

--- Original Message ---

From: "Ayoub Benali" notifications@github.com
Sent: February 9, 2015 7:42 AM
To: "NFLabs/zeppelin" zeppelin@noreply.github.com
Cc: "Felix Cheung" felixcheung_m@hotmail.com
Subject: Re: [zeppelin] Spark 1.2 (#294)

Spark repl 1.2.1 is now available in maven central so I guess everyone should be able to build zeppeling against spark 1.2.X


Reply to this email directly or view it on GitHub:
#294 (comment)

@gtinside
Copy link

gtinside commented Feb 9, 2015

Yeah , I was successful in building the zeppelin-master with spark 1.2 , but getting exception while creating sql context. I updated the pom to get appropriate netty jar (4.0.17.Final)

Exception in thread "Thread-41" java.lang.NoSuchMethodError: io.netty.buffer.PooledByteBufAllocator.(ZIIIIIII)V
at org.apache.spark.network.util.NettyUtils.createPooledByteBufAllocator(NettyUtils.java:123)
at org.apache.spark.network.client.TransportClientFactory.(TransportClientFactory.java:105)
at org.apache.spark.network.TransportContext.createClientFactory(TransportContext.java:77)
at org.apache.spark.network.netty.NettyBlockTransferService.init(NettyBlockTransferService.scala:62)
at org.apache.spark.storage.BlockManager.initialize(BlockManager.scala:194)
at org.apache.spark.SparkContext.(SparkContext.scala:340)
at com.nflabs.zeppelin.spark.SparkInterpreter.createSparkContext(SparkInterpreter.java:172)
at com.nflabs.zeppelin.spark.SparkInterpreter.getSparkContext(SparkInterpreter.java:109)

Can someone please help me here ?

Regards,
Gaurav

@ayoub-benali
Copy link

@felixcheung spark 1.2.1 is just for bug fixes just like the other minor version. So there should be no breaking changes.

Plus I am not sure that they will publish the repl for spark 1.2.0

@felixcheung
Copy link
Contributor

I think you have a mismatch version of Netty.

I had removed the version element for io.netty in the pom file under spark (ie. Spark interpreter) and that worked for me.

Also, I had to add spark-catalyst to dependency.

Hope this helps.

--- Original Message ---

From: "gtinside" notifications@github.com
Sent: February 9, 2015 11:55 AM
To: "NFLabs/zeppelin" zeppelin@noreply.github.com
Cc: "Felix Cheung" felixcheung_m@hotmail.com
Subject: Re: [zeppelin] Spark 1.2 (#294)

Yeah , I was successful in building the zeppelin-master with spark 1.2 , but getting exception while creating sql context. I updated the pom to get appropriate netty jar (4.0.17.Final)

Exception in thread "Thread-41" java.lang.NoSuchMethodError: io.netty.buffer.PooledByteBufAllocator.(ZIIIIIII)V
at org.apache.spark.network.util.NettyUtils.createPooledByteBufAllocator(NettyUtils.java:123)
at org.apache.spark.network.client.TransportClientFactory.(TransportClientFactory.java:105)
at org.apache.spark.network.TransportContext.createClientFactory(TransportContext.java:77)
at org.apache.spark.network.netty.NettyBlockTransferService.init(NettyBlockTransferService.scala:62)
at org.apache.spark.storage.BlockManager.initialize(BlockManager.scala:194)
at org.apache.spark.SparkContext.(SparkContext.scala:340)
at com.nflabs.zeppelin.spark.SparkInterpreter.createSparkContext(SparkInterpreter.java:172)
at com.nflabs.zeppelin.spark.SparkInterpreter.getSparkContext(SparkInterpreter.java:109)

Can someone please help me here ?

Regards,
Gaurav


Reply to this email directly or view it on GitHub:
#294 (comment)

@felixcheung
Copy link
Contributor

Thanks. I'm aware. I have clusters on 1.2.0 and they are out of my control.

I was running 1.2 before it was released on my Dev box ;)

--- Original Message ---

From: "Ayoub Benali" notifications@github.com
Sent: February 9, 2015 1:24 PM
To: "NFLabs/zeppelin" zeppelin@noreply.github.com
Cc: "Felix Cheung" felixcheung_m@hotmail.com
Subject: Re: [zeppelin] Spark 1.2 (#294)

@felixcheung spark 1.2.1 is just for bug fixes just like the other minor version. So there should be no breaking changes.

Plus I am not sure that they will publish the repl for spark 1.2.0


Reply to this email directly or view it on GitHub:
#294 (comment)

@swkimme
Copy link
Contributor

swkimme commented Feb 10, 2015

Guys, you would know Spark 1.2.1 (bug fixes, stability) is just released and recommended for all 1.2.0 users to upgrade to 1.2.1. Go for it!

@Leemoonsoo
Copy link
Contributor Author

I'm trying with 1.2.1, It works.

But if i run it on eclipse IDE (my development environment), i got exception with rdd.registerTempTable()

scala.reflect.internal.MissingRequirementError: class org.apache.spark.sql.catalyst.ScalaReflection in JavaMirror with sun.misc.Launcher$AppClassLoader@530f243b of type class sun.misc.Launcher$AppClassLoader with classpath [file:/Users/moon/Projects/zeppelin/zeppelin-server/target/test-classes/,file:/Users/moon/Projects/zeppelin/zeppelin-server/target/classes/,file:/Users/moon/.m2/repository/javax/ws/rs/jsr311-api/1.1.1/jsr311-api-1.1.1.jar,file:/Users/moon/.m2/repository/javax/ws/rs/javax.ws.rs-api/2.0-m10/javax.ws.rs-api-2.0-m10.jar,file:/Users/moon/Projects/zeppelin/zeppelin-zengine/target/test-classes/,file:/Users/moon/Projects/zeppelin/zeppelin-zengine/target/classes/,file:/Users/moon/.m2/repository/org/slf4j/slf4j-api/1.7.5/slf4j-api-1.7.5.jar,file:/Users/moon/.m2/repository/org/slf4j/slf4j-log4j12/1.7.5/slf4j-log4j12-1.7.5.jar,file:/Users/moon/.m2/repository/log4j/log4j/1.2.17/log4j-1.2.17.jar,file:/Users/moon/.m2/repository/commons-configuration/commons-configuration/1.9/commons-configuration-1.9.jar,file:/Users/moon/.m2/repository/commons-lang/commons-lang/2.5/commons-lang-2.5.jar,file:/Users/moon/.m2/repository/commons-io/commons-io/2.4/commons-io-2.4.jar,file:/Users/moon/.m2/repository/commons-logging/commons-logging/1.1.1/commons-logging-1.1.1.jar,file:/Users/moon/.m2/repository/org/quartz-scheduler/quartz/2.2.1/quartz-2.2.1.jar,file:/Users/moon/.m2/repository/c3p0/c3p0/0.9.1.1/c3p0-0.9.1.1.jar,file:/Users/moon/.m2/repository/com/google/code/gson/gson/2.1/gson-2.1.jar,file:/Users/moon/.m2/repository/com/google/guava/guava/15.0/guava-15.0.jar,file:/Users/moon/.m2/repository/junit/junit/4.11/junit-4.11.jar,file:/Users/moon/.m2/repository/org/hamcrest/hamcrest-core/1.3/hamcrest-core-1.3.jar,file:/Users/moon/.m2/repository/org/reflections/reflections/0.9.8/reflections-0.9.8.jar,file:/Users/moon/.m2/repository/javassist/javassist/3.12.1.GA/javassist-3.12.1.GA.jar,file:/Users/moon/.m2/repository/dom4j/dom4j/1.6.1/dom4j-1.6.1.jar,file:/Users/moon/.m2/repository/xml-apis/xml-apis/1.4.01/xml-apis-1.4.01.jar,file:/Users/moon/.m2/repository/org/apache/cxf/cxf-rt-frontend-jaxrs/2.7.7/cxf-rt-frontend-jaxrs-2.7.7.jar,file:/Users/moon/.m2/repository/org/apache/cxf/cxf-api/2.7.7/cxf-api-2.7.7.jar,file:/Users/moon/.m2/repository/org/codehaus/woodstox/woodstox-core-asl/4.2.0/woodstox-core-asl-4.2.0.jar,file:/Users/moon/.m2/repository/org/codehaus/woodstox/stax2-api/3.1.1/stax2-api-3.1.1.jar,file:/Users/moon/.m2/repository/org/apache/ws/xmlschema/xmlschema-core/2.0.3/xmlschema-core-2.0.3.jar,file:/Users/moon/.m2/repository/org/apache/geronimo/specs/geronimo-javamail_1.4_spec/1.7.1/geronimo-javamail_1.4_spec-1.7.1.jar,file:/Users/moon/.m2/repository/wsdl4j/wsdl4j/1.6.3/wsdl4j-1.6.3.jar,file:/Users/moon/.m2/repository/org/apache/cxf/cxf-rt-core/2.7.7/cxf-rt-core-2.7.7.jar,file:/Users/moon/.m2/repository/com/sun/xml/bind/jaxb-impl/2.2.6/jaxb-impl-2.2.6.jar,file:/Users/moon/.m2/repository/org/apache/cxf/cxf-rt-bindings-xml/2.7.7/cxf-rt-bindings-xml-2.7.7.jar,file:/Users/moon/.m2/repository/org/apache/cxf/cxf-rt-transports-http/2.7.7/cxf-rt-transports-http-2.7.7.jar,file:/Users/moon/.m2/repository/org/java-websocket/Java-WebSocket/1.3.0/Java-WebSocket-1.3.0.jar,file:/Users/moon/.m2/repository/com/wordnik/swagger-jersey-jaxrs_2.10/1.3.0/swagger-jersey-jaxrs_2.10-1.3.0.jar,file:/Users/moon/.m2/repository/com/wordnik/swagger-jaxrs_2.10/1.3.0/swagger-jaxrs_2.10-1.3.0.jar,file:/Users/moon/.m2/repository/org/scala-lang/scala-library/2.10.4/scala-library-2.10.4.jar,file:/Users/moon/.m2/repository/com/wordnik/swagger-core_2.10/1.3.0/swagger-core_2.10-1.3.0.jar,file:/Users/moon/.m2/repository/com/fasterxml/jackson/module/jackson-module-jsonSchema/2.1.0/jackson-module-jsonSchema-2.1.0.jar,file:/Users/moon/.m2/repository/com/fasterxml/jackson/jaxrs/jackson-jaxrs-json-provider/2.0.0/jackson-jaxrs-json-provider-2.0.0.jar,file:/Users/moon/.m2/repository/com/fasterxml/jackson/module/jackson-module-jaxb-annotations/2.0.0/jackson-module-jaxb-annotations-2.0.0.jar,file:/Users/moon/.m2/repository/com/wordnik/swagger-annotations_2.10/1.3.0/swagger-annotations_2.10-1.3.0.jar,file:/Users/moon/.m2/repository/org/json4s/json4s-ext_2.10/3.2.4/json4s-ext_2.10-3.2.4.jar,file:/Users/moon/.m2/repository/joda-time/joda-time/2.1/joda-time-2.1.jar,file:/Users/moon/.m2/repository/org/joda/joda-convert/1.2/joda-convert-1.2.jar,file:/Users/moon/.m2/repository/org/json4s/json4s-native_2.10/3.2.4/json4s-native_2.10-3.2.4.jar,file:/Users/moon/.m2/repository/com/sun/jersey/contribs/jersey-multipart/1.13/jersey-multipart-1.13.jar,file:/Users/moon/.m2/repository/org/jvnet/mimepull/1.6/mimepull-1.6.jar,file:/Users/moon/.m2/repository/com/sun/jersey/jersey-core/1.9/jersey-core-1.9.jar,file:/Users/moon/.m2/repository/com/sun/jersey/jersey-client/1.9/jersey-client-1.9.jar,file:/Users/moon/.m2/repository/com/sun/jersey/jersey-server/1.9/jersey-server-1.9.jar,file:/Users/moon/.m2/repository/asm/asm/3.1/asm-3.1.jar,file:/Users/moon/.m2/repository/org/apache/cxf/cxf-rt-transports-http-jetty/2.7.7/cxf-rt-transports-http-jetty-2.7.7.jar,file:/Users/moon/.m2/repository/org/apache/geronimo/specs/geronimo-servlet_3.0_spec/1.0/geronimo-servlet_3.0_spec-1.0.jar,file:/Users/moon/.m2/repository/org/eclipse/jetty/aggregate/jetty-all-server/8.1.14.v20131031/jetty-all-server-8.1.14.v20131031.jar,file:/Users/moon/.m2/repository/org/eclipse/jetty/orbit/javax.servlet/3.0.0.v201112011016/javax.servlet-3.0.0.v201112011016.jar,file:/Users/moon/.m2/repository/org/eclipse/jetty/orbit/javax.security.auth.message/1.0.0.v201108011116/javax.security.auth.message-1.0.0.v201108011116.jar,file:/Users/moon/.m2/repository/org/eclipse/jetty/orbit/javax.mail.glassfish/1.4.1.v201005082020/javax.mail.glassfish-1.4.1.v201005082020.jar,file:/Users/moon/.m2/repository/org/eclipse/jetty/orbit/javax.activation/1.1.0.v201105071233/javax.activation-1.1.0.v201105071233.jar,file:/Users/moon/.m2/repository/org/eclipse/jetty/orbit/javax.annotation/1.1.0.v201108011116/javax.annotation-1.1.0.v201108011116.jar,file:/Users/moon/.m2/repository/org/eclipse/jetty/jetty-jsp/8.1.14.v20131031/jetty-jsp-8.1.14.v20131031.jar,file:/Users/moon/.m2/repository/org/eclipse/jetty/orbit/javax.servlet.jsp.jstl/1.2.0.v201105211821/javax.servlet.jsp.jstl-1.2.0.v201105211821.jar,file:/Users/moon/.m2/repository/org/eclipse/jetty/orbit/org.apache.taglibs.standard.glassfish/1.2.0.v201112081803/org.apache.taglibs.standard.glassfish-1.2.0.v201112081803.jar,file:/Users/moon/.m2/repository/org/eclipse/jetty/orbit/javax.el/2.2.0.v201108011116/javax.el-2.2.0.v201108011116.jar,file:/Users/moon/.m2/repository/org/eclipse/jetty/orbit/com.sun.el/2.2.0.v201108011116/com.sun.el-2.2.0.v201108011116.jar,file:/Users/moon/.m2/repository/org/eclipse/jetty/orbit/org.eclipse.jdt.core/3.7.1/org.eclipse.jdt.core-3.7.1.jar,file:/Users/moon/.m2/repository/org/eclipse/jetty/orbit/javax.servlet.jsp/2.2.0.v201112011158/javax.servlet.jsp-2.2.0.v201112011158.jar,file:/Users/moon/.m2/repository/commons-httpclient/commons-httpclient/3.1/commons-httpclient-3.1.jar,file:/Users/moon/.m2/repository/org/seleniumhq/selenium/selenium-java/2.44.0/selenium-java-2.44.0.jar,file:/Users/moon/.m2/repository/org/seleniumhq/selenium/selenium-chrome-driver/2.44.0/selenium-chrome-driver-2.44.0.jar,file:/Users/moon/.m2/repository/org/seleniumhq/selenium/selenium-remote-driver/2.44.0/selenium-remote-driver-2.44.0.jar,file:/Users/moon/.m2/repository/cglib/cglib-nodep/2.1_3/cglib-nodep-2.1_3.jar,file:/Users/moon/.m2/repository/org/seleniumhq/selenium/selenium-api/2.44.0/selenium-api-2.44.0.jar,file:/Users/moon/.m2/repository/org/apache/httpcomponents/httpclient/4.2.6/httpclient-4.2.6.jar,file:/Users/moon/.m2/repository/org/apache/httpcomponents/httpcore/4.3.3/httpcore-4.3.3.jar,file:/Users/moon/.m2/repository/commons-codec/commons-codec/1.5/commons-codec-1.5.jar,file:/Users/moon/.m2/repository/org/apache/commons/commons-exec/1.1/commons-exec-1.1.jar,file:/Users/moon/.m2/repository/net/java/dev/jna/jna/3.4.0/jna-3.4.0.jar,file:/Users/moon/.m2/repository/net/java/dev/jna/platform/3.4.0/platform-3.4.0.jar,file:/Users/moon/.m2/repository/org/seleniumhq/selenium/selenium-htmlunit-driver/2.44.0/selenium-htmlunit-driver-2.44.0.jar,file:/Users/moon/.m2/repository/net/sourceforge/htmlunit/htmlunit/2.15/htmlunit-2.15.jar,file:/Users/moon/.m2/repository/xalan/xalan/2.7.1/xalan-2.7.1.jar,file:/Users/moon/.m2/repository/xalan/serializer/2.7.1/serializer-2.7.1.jar,file:/Users/moon/.m2/repository/commons-collections/commons-collections/3.2.1/commons-collections-3.2.1.jar,file:/Users/moon/.m2/repository/org/apache/commons/commons-lang3/3.3.2/commons-lang3-3.3.2.jar,file:/Users/moon/.m2/repository/org/apache/httpcomponents/httpmime/4.3.3/httpmime-4.3.3.jar,file:/Users/moon/.m2/repository/net/sourceforge/htmlunit/htmlunit-core-js/2.15/htmlunit-core-js-2.15.jar,file:/Users/moon/.m2/repository/xerces/xercesImpl/2.11.0/xercesImpl-2.11.0.jar,file:/Users/moon/.m2/repository/net/sourceforge/nekohtml/nekohtml/1.9.21/nekohtml-1.9.21.jar,file:/Users/moon/.m2/repository/net/sourceforge/cssparser/cssparser/0.9.14/cssparser-0.9.14.jar,file:/Users/moon/.m2/repository/org/w3c/css/sac/1.3/sac-1.3.jar,file:/Users/moon/.m2/repository/org/eclipse/jetty/jetty-websocket/8.1.15.v20140411/jetty-websocket-8.1.15.v20140411.jar,file:/Users/moon/.m2/repository/org/eclipse/jetty/jetty-util/8.1.14.v20131031/jetty-util-8.1.14.v20131031.jar,file:/Users/moon/.m2/repository/org/eclipse/jetty/jetty-io/8.1.15.v20140411/jetty-io-8.1.15.v20140411.jar,file:/Users/moon/.m2/repository/org/eclipse/jetty/jetty-http/8.1.15.v20140411/jetty-http-8.1.15.v20140411.jar,file:/Users/moon/.m2/repository/org/seleniumhq/selenium/selenium-firefox-driver/2.44.0/selenium-firefox-driver-2.44.0.jar,file:/Users/moon/.m2/repository/org/seleniumhq/selenium/selenium-ie-driver/2.44.0/selenium-ie-driver-2.44.0.jar,file:/Users/moon/.m2/repository/org/seleniumhq/selenium/selenium-safari-driver/2.44.0/selenium-safari-driver-2.44.0.jar,file:/Users/moon/.m2/repository/org/webbitserver/webbit/0.4.14/webbit-0.4.14.jar,file:/Users/moon/.m2/repository/io/netty/netty/3.6.6.Final/netty-3.6.6.Final.jar,file:/Users/moon/.m2/repository/org/seleniumhq/selenium/selenium-support/2.44.0/selenium-support-2.44.0.jar,file:/Users/moon/.m2/repository/org/atmosphere/atmosphere-jersey/2.2.0/atmosphere-jersey-2.2.0.jar,file:/Users/moon/.m2/repository/org/atmosphere/atmosphere-annotations/2.2.0/atmosphere-annotations-2.2.0.jar,file:/Users/moon/.m2/repository/org/atmosphere/atmosphere-runtime/2.2.0/atmosphere-runtime-2.2.0.jar,file:/Users/moon/.m2/repository/com/sun/jersey/jersey-servlet/1.18.1/jersey-servlet-1.18.1.jar,file:/Users/moon/.m2/repository/org/scalatest/scalatest_2.10/2.1.5/scalatest_2.10-2.1.5.jar,file:/Users/moon/.m2/repository/org/scala-lang/scala-reflect/2.10.4/scala-reflect-2.10.4.jar] and parent being sun.misc.Launcher$ExtClassLoader@713c817 of type class sun.misc.Launcher$ExtClassLoader with classpath [file:/Library/Java/JavaVirtualMachines/jdk1.7.0_45.jdk/Contents/Home/jre/lib/ext/dnsns.jar,file:/Library/Java/JavaVirtualMachines/jdk1.7.0_45.jdk/Contents/Home/jre/lib/ext/localedata.jar,file:/Library/Java/JavaVirtualMachines/jdk1.7.0_45.jdk/Contents/Home/jre/lib/ext/sunec.jar,file:/Library/Java/JavaVirtualMachines/jdk1.7.0_45.jdk/Contents/Home/jre/lib/ext/sunjce_provider.jar,file:/Library/Java/JavaVirtualMachines/jdk1.7.0_45.jdk/Contents/Home/jre/lib/ext/sunpkcs11.jar,file:/Library/Java/JavaVirtualMachines/jdk1.7.0_45.jdk/Contents/Home/jre/lib/ext/zipfs.jar,file:/System/Library/Java/Extensions/MRJToolkit.jar] and parent being primordial classloader with boot classpath [/Library/Java/JavaVirtualMachines/jdk1.7.0_45.jdk/Contents/Home/jre/lib/resources.jar:/Library/Java/JavaVirtualMachines/jdk1.7.0_45.jdk/Contents/Home/jre/lib/rt.jar:/Library/Java/JavaVirtualMachines/jdk1.7.0_45.jdk/Contents/Home/jre/lib/sunrsasign.jar:/Library/Java/JavaVirtualMachines/jdk1.7.0_45.jdk/Contents/Home/jre/lib/jsse.jar:/Library/Java/JavaVirtualMachines/jdk1.7.0_45.jdk/Contents/Home/jre/lib/jce.jar:/Library/Java/JavaVirtualMachines/jdk1.7.0_45.jdk/Contents/Home/jre/lib/charsets.jar:/Library/Java/JavaVirtualMachines/jdk1.7.0_45.jdk/Contents/Home/jre/lib/jfr.jar:/Library/Java/JavaVirtualMachines/jdk1.7.0_45.jdk/Contents/Home/jre/lib/JObjC.jar:/Library/Java/JavaVirtualMachines/jdk1.7.0_45.jdk/Contents/Home/jre/classes] not found.
    at scala.reflect.internal.MissingRequirementError$.signal(MissingRequirementError.scala:16)
    at scala.reflect.internal.MissingRequirementError$.notFound(MissingRequirementError.scala:17)
    at scala.reflect.internal.Mirrors$RootsBase.getModuleOrClass(Mirrors.scala:48)
    at scala.reflect.internal.Mirrors$RootsBase.getModuleOrClass(Mirrors.scala:61)
    at scala.reflect.internal.Mirrors$RootsBase.staticModuleOrClass(Mirrors.scala:72)
    at scala.reflect.internal.Mirrors$RootsBase.staticClass(Mirrors.scala:119)
    at scala.reflect.internal.Mirrors$RootsBase.staticClass(Mirrors.scala:21)
    at org.apache.spark.sql.catalyst.ScalaReflection$$typecreator1$1.apply(ScalaReflection.scala:115)
    at scala.reflect.api.TypeTags$WeakTypeTagImpl.tpe$lzycompute(TypeTags.scala:231)
    at scala.reflect.api.TypeTags$WeakTypeTagImpl.tpe(TypeTags.scala:231)
    at scala.reflect.api.TypeTags$class.typeOf(TypeTags.scala:335)
    at scala.reflect.api.Universe.typeOf(Universe.scala:59)
    at org.apache.spark.sql.catalyst.ScalaReflection$class.schemaFor(ScalaReflection.scala:115)
    at org.apache.spark.sql.catalyst.ScalaReflection$.schemaFor(ScalaReflection.scala:33)
    at org.apache.spark.sql.catalyst.ScalaReflection$class.schemaFor(ScalaReflection.scala:100)
    at org.apache.spark.sql.catalyst.ScalaReflection$.schemaFor(ScalaReflection.scala:33)
    at org.apache.spark.sql.catalyst.ScalaReflection$class.attributesFor(ScalaReflection.scala:94)
    at org.apache.spark.sql.catalyst.ScalaReflection$.attributesFor(ScalaReflection.scala:33)
    at org.apache.spark.sql.SQLContext.createSchemaRDD(SQLContext.scala:111)
    at $iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:24)
    at $iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:29)
    at $iwC$$iwC$$iwC$$iwC.<init>(<console>:31)
    at $iwC$$iwC$$iwC.<init>(<console>:33)
    at $iwC$$iwC.<init>(<console>:35)
    at $iwC.<init>(<console>:37)
    at <init>(<console>:39)
    at .<init>(<console>:43)
    at .<clinit>(<console>)
    at .<init>(<console>:7)
    at .<clinit>(<console>)
    at $print(<console>)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:606)
    at org.apache.spark.repl.SparkIMain$ReadEvalPrint.call(SparkIMain.scala:852)
    at org.apache.spark.repl.SparkIMain$Request.loadAndRun(SparkIMain.scala:1125)
    at org.apache.spark.repl.SparkIMain.loadAndRunReq$1(SparkIMain.scala:674)
    at org.apache.spark.repl.SparkIMain.interpret(SparkIMain.scala:705)
    at org.apache.spark.repl.SparkIMain.interpret(SparkIMain.scala:669)
    at com.nflabs.zeppelin.spark.SparkInterpreter.interpretInput(SparkInterpreter.java:369)
    at com.nflabs.zeppelin.spark.SparkInterpreter.interpret(SparkInterpreter.java:345)
    at com.nflabs.zeppelin.spark.SparkInterpreter.interpret(SparkInterpreter.java:339)
    at com.nflabs.zeppelin.interpreter.ClassloaderInterpreter.interpret(ClassloaderInterpreter.java:54)
    at com.nflabs.zeppelin.interpreter.LazyOpenInterpreter.interpret(LazyOpenInterpreter.java:77)
    at com.nflabs.zeppelin.notebook.Paragraph.jobRun(Paragraph.java:184)
    at com.nflabs.zeppelin.scheduler.Job.run(Job.java:147)
    at com.nflabs.zeppelin.scheduler.FIFOScheduler$1.run(FIFOScheduler.java:85)
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
    at java.util.concurrent.FutureTask.run(FutureTask.java:262)
    at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:178)
    at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:292)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
    at java.lang.Thread.run(Thread.java:744)

related issue
https://issues.apache.org/jira/browse/SPARK-5281

It's fine with bin/zeppelin-daemon.sh start

@@ -100,9 +102,12 @@
<codahale.metrics.version>3.0.0</codahale.metrics.version>
<avro.version>1.7.6</avro.version>
<jets3t.version>0.7.1</jets3t.version>
<commons.math3.version>3.2</commons.math3.version>
<commons.httpclient.version>4.3.6</commons.httpclient.version>
<io.netty.version>4.0.17.Final</io.netty.version>

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

update please version of netty to latest version 4.0.25.Final
because spark 1.2.0+ use PooledByteBufAllocator with 8 parameters, which introduced in 4.0.18.Final
without update netty we have
java.lang.NoSuchMethodError: io.netty.buffer.PooledByteBufAllocator.(ZIIIIIII)V
in spark.version=1.2.0-cdh5.3.1when create SparkContext

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

@xhumanoid
Thanks for reporting problem. Zeppelin enables spark-1.2.0+ support by setting maven profile 'spark-1.2'. Profile 'spark-1.2' overrides io.netty.version to '4.0.23.Final' (line 1223). So, i think it's okay with 'spark-1.2' profile.

@Leemoonsoo
Copy link
Contributor Author

Since spark-repl-1.2.1 artifact is published, it's ready to be merged.

@swkimme
Copy link
Contributor

swkimme commented Feb 11, 2015

Let's merge it.

On Wed Feb 11 2015 at 4:48:04 PM Lee moon soo notifications@github.com
wrote:

Since spark-repl-1.2.1 artifact is published, it's ready to be merged.


Reply to this email directly or view it on GitHub
#294 (comment).

Leemoonsoo added a commit that referenced this pull request Feb 12, 2015
@Leemoonsoo Leemoonsoo merged commit 22e44c3 into interpreter_binding Feb 12, 2015
@Leemoonsoo Leemoonsoo deleted the spark_1.2 branch February 12, 2015 03:03
@jongyoul
Copy link
Contributor

+1 @Leemoonsoo

@swkimme
Copy link
Contributor

swkimme commented Feb 12, 2015

Guys, it seems there is a critical issue with spark 1.2 + Zeppelin.

https://github.com/NFLabs/zeppelin/issues/339
Watch out! and plz add comment if you got similar exception.

epahomov pushed a commit to epahomov/zeppelin that referenced this pull request Jul 23, 2016
This PR fixes ZEPPELIN-298 by searching correct "addListener" method which have JobProgressListener as a parameter.

Author: Lee moon soo <moon@apache.org>

Closes ZEPL#294 from Leemoonsoo/ZEPPELIN-298 and squashes the following commits:

6fb2397 [Lee moon soo] Fix job progress listener registration
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet