Run interpreter on separate JVM #364

Leemoonsoo · 2015-02-26T06:50:53Z

Running interpreter in separate process discussed in #278 and mailinglist. @bzz made PoC of it https://github.com/bzz/zeppelin-multiprocess-interpreter-poc

This PR implements #278 using thrift.

swkimme · 2015-02-27T06:23:24Z

I've failed to launch Zeppelin in this branch. Attaching log.

==> ./logs/zeppelin-swkim-SangWoos-MacBook-Pro.local.out <==
SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in [jar:file:/Users/swkim/Documents/zeppelin/zeppelin-server/target/lib/slf4j-log4j12-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/Users/swkim/Documents/zeppelin/zeppelin-zengine/target/lib/slf4j-log4j12-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/Users/swkim/Documents/zeppelin/zeppelin-interpreter/target/lib/slf4j-log4j12-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
SLF4J: Actual binding is of type [org.slf4j.impl.Log4jLoggerFactory]

==> ./logs/zeppelin-swkim-SangWoos-MacBook-Pro.local.log <==
WARN [2015-02-27 15:22:47,417]({main} ZeppelinConfiguration.java[create]:76) - Failed to load configuration, proceeding with a default
INFO [2015-02-27 15:22:47,593]({main} NotebookServer.java[creatingwebSocketServerLog]:41) - Create zeppelin websocket on port 8081
INFO [2015-02-27 15:22:47,826]({main} ZeppelinServer.java[main]:82) - Start zeppelin server
INFO [2015-02-27 15:22:47,830]({main} Server.java[doStart]:272) - jetty-8.1.14.v20131031
INFO [2015-02-27 15:22:48,257]({main} InterpreterFactory.java[init]:79) - Reading /Users/swkim/Documents/zeppelin/interpreter/md
INFO [2015-02-27 15:22:48,266]({main} InterpreterFactory.java[init]:96) - Interpreter md found. class=com.nflabs.zeppelin.markdown.Markdown
INFO [2015-02-27 15:22:48,266]({main} InterpreterFactory.java[init]:79) - Reading /Users/swkim/Documents/zeppelin/interpreter/sh
INFO [2015-02-27 15:22:48,278]({main} InterpreterFactory.java[init]:96) - Interpreter sh found. class=com.nflabs.zeppelin.shell.ShellInterpreter
INFO [2015-02-27 15:22:48,278]({main} InterpreterFactory.java[init]:79) - Reading /Users/swkim/Documents/zeppelin/interpreter/spark
INFO [2015-02-27 15:22:48,379]({main} InterpreterFactory.java[init]:96) - Interpreter spark found. class=com.nflabs.zeppelin.spark.SparkInterpreter
INFO [2015-02-27 15:22:48,389]({main} InterpreterFactory.java[init]:96) - Interpreter sql found. class=com.nflabs.zeppelin.spark.SparkSqlInterpreter
INFO [2015-02-27 15:22:48,393]({main} InterpreterFactory.java[init]:96) - Interpreter dep found. class=com.nflabs.zeppelin.spark.DepInterpreter
INFO [2015-02-27 15:22:48,415]({main} InterpreterFactory.java[createRepl]:503) - Create repl com.nflabs.zeppelin.shell.ShellInterpreter from /Users/swkim/Documents/zeppelin/interpreter/sh
INFO [2015-02-27 15:22:48,418]({main} InterpreterFactory.java[createRepl]:503) - Create repl com.nflabs.zeppelin.spark.SparkInterpreter from /Users/swkim/Documents/zeppelin/interpreter/spark
INFO [2015-02-27 15:22:48,423]({main} InterpreterFactory.java[createRepl]:503) - Create repl com.nflabs.zeppelin.spark.SparkSqlInterpreter from /Users/swkim/Documents/zeppelin/interpreter/spark
INFO [2015-02-27 15:22:48,424]({main} InterpreterFactory.java[createRepl]:503) - Create repl com.nflabs.zeppelin.spark.DepInterpreter from /Users/swkim/Documents/zeppelin/interpreter/spark
INFO [2015-02-27 15:22:48,427]({main} InterpreterFactory.java[createRepl]:503) - Create repl com.nflabs.zeppelin.markdown.Markdown from /Users/swkim/Documents/zeppelin/interpreter/md
INFO [2015-02-27 15:22:48,428]({main} InterpreterFactory.java[init]:154) - Interpreter setting group sh : id=2AHXRKVFG, name=sh
INFO [2015-02-27 15:22:48,428]({main} InterpreterFactory.java[init]:157) - className = com.nflabs.zeppelin.shell.ShellInterpreter
INFO [2015-02-27 15:22:48,428]({main} InterpreterFactory.java[init]:154) - Interpreter setting group spark : id=2AH9MEKF8, name=spark
INFO [2015-02-27 15:22:48,428]({main} InterpreterFactory.java[init]:157) - className = com.nflabs.zeppelin.spark.SparkInterpreter
INFO [2015-02-27 15:22:48,429]({main} InterpreterFactory.java[init]:157) - className = com.nflabs.zeppelin.spark.SparkSqlInterpreter
INFO [2015-02-27 15:22:48,429]({main} InterpreterFactory.java[init]:157) - className = com.nflabs.zeppelin.spark.DepInterpreter
INFO [2015-02-27 15:22:48,429]({main} InterpreterFactory.java[init]:154) - Interpreter setting group md : id=2AFTTP29X, name=md
INFO [2015-02-27 15:22:48,429]({main} InterpreterFactory.java[init]:157) - className = com.nflabs.zeppelin.markdown.Markdown
INFO [2015-02-27 15:22:48,463]({main} StdSchedulerFactory.java[instantiate]:1184) - Using default implementation for ThreadExecutor
INFO [2015-02-27 15:22:48,466]({main} SimpleThreadPool.java[initialize]:268) - Job execution threads will use class loader of thread: main
INFO [2015-02-27 15:22:48,481]({main} SchedulerSignalerImpl.java[]:61) - Initialized Scheduler Signaller of type: class org.quartz.core.SchedulerSignalerImpl
INFO [2015-02-27 15:22:48,482]({main} QuartzScheduler.java[]:240) - Quartz Scheduler v.2.2.1 created.
INFO [2015-02-27 15:22:48,483]({main} RAMJobStore.java[initialize]:155) - RAMJobStore initialized.
INFO [2015-02-27 15:22:48,484]({main} QuartzScheduler.java[initialize]:305) - Scheduler meta-data: Quartz Scheduler (v2.2.1) 'DefaultQuartzScheduler' with instanceId 'NON_CLUSTERED'
Scheduler class: 'org.quartz.core.QuartzScheduler' - running locally.
NOT STARTED.
Currently in standby mode.
Number of jobs executed: 0
Using thread pool 'org.quartz.simpl.SimpleThreadPool' - with 10 threads.
Using job-store 'org.quartz.simpl.RAMJobStore' - which does not support persistence. and is not clustered.

INFO [2015-02-27 15:22:48,484]({main} StdSchedulerFactory.java[instantiate]:1339) - Quartz scheduler 'DefaultQuartzScheduler' initialized from default resource file in Quartz package: 'quartz.properties'
INFO [2015-02-27 15:22:48,484]({main} StdSchedulerFactory.java[instantiate]:1343) - Quartz scheduler version: 2.2.1
INFO [2015-02-27 15:22:48,485]({main} QuartzScheduler.java[start]:575) - Scheduler DefaultQuartzScheduler_$_NON_CLUSTERED started.
INFO [2015-02-27 15:22:48,696]({main} ServerImpl.java[initDestination]:94) - Setting the server's publish address to be /
INFO [2015-02-27 15:22:48,853]({main} StandardDescriptorProcessor.java[visitServlet]:284) - NO JSP Support for /, did not find org.apache.jasper.servlet.JspServlet

==> ./logs/zeppelin-swkim-SangWoos-MacBook-Pro.local.out <==
Feb 27, 2015 3:22:48 PM com.sun.jersey.api.core.PackagesResourceConfig init
INFO: Scanning for root resource and provider classes in the packages:
com.nflabs.zeppelin.rest
com.wordnik.swagger.jersey.listing
Feb 27, 2015 3:22:48 PM com.sun.jersey.api.core.ScanningResourceConfig logClasses
INFO: Root resource classes found:
class com.nflabs.zeppelin.rest.InterpreterRestApi
class com.wordnik.swagger.jersey.listing.ApiListingResourceJSON
class com.nflabs.zeppelin.rest.NotebookRestApi
class com.nflabs.zeppelin.rest.ZeppelinRestApi
Feb 27, 2015 3:22:48 PM com.sun.jersey.api.core.ScanningResourceConfig logClasses
INFO: Provider classes found:
class com.wordnik.swagger.jersey.listing.JerseyResourceListingProvider
class com.wordnik.swagger.jersey.listing.JerseyApiDeclarationProvider
Feb 27, 2015 3:22:49 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Feb 27, 2015 3:22:49 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Adding the following classes declared in META-INF/services/jersey-server-components to the resource configuration:
class org.atmosphere.jersey.AtmosphereResourceConfigurator
Feb 27, 2015 3:22:49 PM com.sun.jersey.spi.inject.Errors processErrorMessages
WARNING: The following warnings have been detected with resource and/or provider classes:
WARNING: A HTTP GET method, public javax.ws.rs.core.Response com.nflabs.zeppelin.rest.InterpreterRestApi.listInterpreter(java.lang.String), should not consume any entity.

==> ./logs/zeppelin-swkim-SangWoos-MacBook-Pro.local.log <==
INFO [2015-02-27 15:22:49,802]({main} StandardDescriptorProcessor.java[visitServlet]:284) - NO JSP Support for /docs, did not find org.apache.jasper.servlet.JspServlet
INFO [2015-02-27 15:22:49,809]({main} AbstractConnector.java[doStart]:338) - Started SocketConnector@0.0.0.0:8080
INFO [2015-02-27 15:22:49,809]({main} ZeppelinServer.java[main]:84) - Started
INFO [2015-02-27 15:22:49,810]({Thread-20} ZeppelinServer.java[run]:88) - Shutting down Zeppelin Server ...
INFO [2015-02-27 15:22:49,822]({Thread-20} ELContextCleaner.java[contextDestroyed]:63) - javax.el.BeanELResolver purged
INFO [2015-02-27 15:22:49,823]({Thread-20} ContextHandler.java[doStop]:843) - stopped o.e.j.w.WebAppContext{/docs,file:/Users/swkim/Documents/zeppelin/zeppelin-docs/target/zeppelin-api-ui/},/Users/swkim/Documents/zeppelin/zeppelin-docs/target/zeppelin-api-ui.war
INFO [2015-02-27 15:22:49,824]({Thread-20} ELContextCleaner.java[contextDestroyed]:63) - javax.el.BeanELResolver purged
INFO [2015-02-27 15:22:49,824]({Thread-20} ContextHandler.java[doStop]:843) - stopped o.e.j.w.WebAppContext{/,file:/Users/swkim/Documents/zeppelin/zeppelin-web/src/main/webapp/}
INFO [2015-02-27 15:22:49,826]({Thread-20} ContextHandler.java[doStop]:843) - stopped o.e.j.s.ServletContextHandler{/api,null}
INFO [2015-02-27 15:22:49,826]({Thread-20} ContextHandler.java[doStop]:843) - stopped o.e.j.s.ServletContextHandler{/,null}
INFO [2015-02-27 15:22:49,880]({Thread-20} ZeppelinServer.java[run]:97) - Bye

Leemoonsoo · 2015-02-27T08:12:58Z

@swkimme I've pushed a fix.
FYI, until it get's user interface implemented, to turn this feature on,
you should manually modify the code (InterpreterFactory.java, Line 337) from

intp = createRepl(info.getPath(),

to

intp = createRemoteRepl(info.getPath(),

, to test this branch. (it results all interpreter run in separate process. After GUI implemented, it'll be able to selectively turn on/off)

swkimme · 2015-02-27T10:16:09Z

Now it works!
Let me test more complicated codes.

Leemoonsoo · 2015-02-28T03:34:38Z

I have added gui to control this feature. Check on 'fork' launch interpreter in separate process, in 'interpreter' page.

Don't need modify InterpreterFactory.java, Line 337 manually, anymore, to try this branch.

Conflicts: zeppelin-web/app/scripts/controllers/interpreter.js

swkimme · 2015-03-01T13:18:16Z

I got exception while running %dep

com.nflabs.zeppelin.interpreter.remote.RemoteInterpreter.getFormType(RemoteInterpreter.java:201) 
com.nflabs.zeppelin.interpreter.LazyOpenInterpreter.getFormType(LazyOpenInterpreter.java:84) 
com.nflabs.zeppelin.notebook.Paragraph.jobRun(Paragraph.java:173) 
com.nflabs.zeppelin.scheduler.Job.run(Job.java:147) 
com.nflabs.zeppelin.scheduler.ParallelScheduler$JobRunner.run(ParallelScheduler.java:110) 
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471) 
java.util.concurrent.FutureTask.run(FutureTask.java:262) 
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:178) 
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:292)
 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) 
java.lang.Thread.run(Thread.java:745)

swkimme · 2015-03-01T13:43:16Z

Also got similar exception while running a simple paragraph in spark local mode.

com.nflabs.zeppelin.interpreter.remote.RemoteInterpreter.open(RemoteInterpreter.java:91) 
com.nflabs.zeppelin.interpreter.LazyOpenInterpreter.open(LazyOpenInterpreter.java:52) 
com.nflabs.zeppelin.interpreter.LazyOpenInterpreter.getFormType(LazyOpenInterpreter.java:83) 
com.nflabs.zeppelin.notebook.Paragraph.jobRun(Paragraph.java:173) 
com.nflabs.zeppelin.scheduler.Job.run(Job.java:147) 
com.nflabs.zeppelin.scheduler.ParallelScheduler$JobRunner.run(ParallelScheduler.java:110) 
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471) 
java.util.concurrent.FutureTask.run(FutureTask.java:262) 
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:178) 
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:292) 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) 
java.lang.Thread.run(Thread.java:745)


com.nflabs.zeppelin.interpreter.InterpreterException: com.nflabs.zeppelin.interpreter.InterpreterException: org.apache.thrift.transport.TTransportException: java.net.ConnectException: Connection refused
    at com.nflabs.zeppelin.interpreter.remote.RemoteInterpreter.open(RemoteInterpreter.java:91)
    at com.nflabs.zeppelin.interpreter.LazyOpenInterpreter.open(LazyOpenInterpreter.java:52)
    at com.nflabs.zeppelin.interpreter.LazyOpenInterpreter.getFormType(LazyOpenInterpreter.java:83)
    at com.nflabs.zeppelin.notebook.Paragraph.jobRun(Paragraph.java:173)
    at com.nflabs.zeppelin.scheduler.Job.run(Job.java:147)
    at com.nflabs.zeppelin.scheduler.ParallelScheduler$JobRunner.run(ParallelScheduler.java:110)
    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: com.nflabs.zeppelin.interpreter.InterpreterException: org.apache.thrift.transport.TTransportException: java.net.ConnectException: Connection refused
    at com.nflabs.zeppelin.interpreter.remote.ClientFactory.create(ClientFactory.java:37)
    at com.nflabs.zeppelin.interpreter.remote.ClientFactory.create(ClientFactory.java:21)
    at org.apache.commons.pool2.BasePooledObjectFactory.makeObject(BasePooledObjectFactory.java:60)
    at org.apache.commons.pool2.impl.GenericObjectPool.create(GenericObjectPool.java:861)
    at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:435)
    at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:363)
    at com.nflabs.zeppelin.interpreter.remote.RemoteInterpreterProcess.getClient(RemoteInterpreterProcess.java:114)
    at com.nflabs.zeppelin.interpreter.remote.RemoteInterpreter.open(RemoteInterpreter.java:89)
    ... 12 more
Caused by: org.apache.thrift.transport.TTransportException: java.net.ConnectException: Connection refused
    at org.apache.thrift.transport.TSocket.open(TSocket.java:185)
    at com.nflabs.zeppelin.interpreter.remote.ClientFactory.create(ClientFactory.java:35)
    ... 19 more
Caused by: java.net.ConnectException: Connection refused
    at java.net.PlainSocketImpl.socketConnect(Native Method)
    at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:339)
    at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:200)
    at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:182)
    at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
    at java.net.Socket.connect(Socket.java:579)
    at org.apache.thrift.transport.TSocket.open(TSocket.java:180)
    ... 20 more

swkimme · 2015-03-02T02:41:43Z

I tested this branch,
Works well in overall except the issues I posted above.

Leemoonsoo · 2015-03-02T07:25:22Z

@swkimme I think i fixed exception related to getFormType().

…ce each other.

swkimme · 2015-03-11T10:08:55Z

Possible related issues:
https://issues.apache.org/jira/browse/SPARK-6069
https://issues.apache.org/jira/browse/SPARK-5470
https://issues.apache.org/jira/browse/SPARK-4660

swkimme · 2015-03-11T10:11:38Z

The issue still exists in Spark 1.3.

swkimme · 2015-03-12T04:59:23Z

Created an issue for it.
https://issues.apache.org/jira/browse/SPARK-6299

Leemoonsoo · 2015-03-12T09:15:32Z

Ready to be merged. Please review and test.

This PR resolves classloader issue by separating JVM process. The issues was blocking support for Spark 1.2.x. I'm running this branch with some spark 1.2.1 clusters and everything looks fine to me.

Changes

New submodule (artifact) and package moved
zeppelin-interpreter submodule is created.
Interpreter class (which is base class to develop new interpreter) moved to 'zeppelin-interpreter' from 'zeppelin-zengine'.
Interpreter API changes
public abstract Object getValue(String name);
public abstract void bindValue(String name, Object o);
are removed from Interpreter class
'Fork' option is added
Fork option is added in interpreter setting, to enable/disable separate interpreter process.
Launch script added
launch script for separate JVM process added in bin/interpreter.sh

swkimme · 2015-03-12T10:00:30Z

@Leemoonsoo
Do we need 'fork' option, tough doing fork is default?

Leemoonsoo · 2015-03-12T10:50:58Z

@swkimme
What do you think? Will it be better it always fork without providing option?

swkimme · 2015-03-12T14:09:06Z

@Leemoonsoo
Definitely it is. Is there any expected problem when we remove option and making it always fork?

Leemoonsoo · 2015-03-13T03:08:12Z

@swkimme No problem. I'll update the code to not show 'fork' option.

Leemoonsoo · 2015-03-13T03:36:18Z

@swkimme I've removed fork option.

swkimme · 2015-03-13T03:37:58Z

LGTM and tested with complex codes, works great.

Leemoonsoo · 2015-03-13T07:41:03Z

I'm merging this PR if there're no more discussions!

jongyoul · 2015-03-13T07:55:21Z

@Leemoonsoo This PR doesn't pass ZEPPELIN_JAVA_OPTS. I have a ZEPPELIN_JAVA_OPTS="-Dspark.io.compress.codec=lzf". This is configured on ZeppelinServer but spark doesn't read this. I'm debugging now.

jongyoul · 2015-03-13T08:24:01Z

@Leemoonsoo Unlikely from zeppelin-daemon.sh, interpreter.sh launches interpreter without JAVA_OPTS. Please add this when Z executes remoteInterpreter.

Leemoonsoo · 2015-03-13T08:42:17Z

@jongyoul Thanks for the feedback. I just pushed a fix.

The problem was because of ZEPPELIN_JAVA_OPTS is not used in interpreter JVM process.
For interpreter JVM process ZEPPELIN_INTP_JAVA_OPTS is do the same thing.
And this fix is taking ZEPPELIN_JAVA_OPTS as default value of ZEPPELIN_INTP_JAVA_OPTS.

conf/zeppelin-env.sh.templates have short description.

jongyoul · 2015-03-13T09:02:46Z

@Leemoonsoo Good!

swkimme · 2015-03-13T09:32:41Z

@jongyoul
Oh, I didn't catch that since I don't use ZEPPELIN_JAVA_OPTS today.
Great!

Run interpreter on separate JVM

Update documentation for separate interpreter process #364

This PR came from ZEPL/zeppelin#397 After ZEPL/zeppelin#364, order of submitted job to the remote interpreter is not preserved. Result is, when user run a lot of paragraphs in a short time, they run in random order(like click run 'Run all paragraphs). https://github.com/NFLabs/zeppelin/issues/395 is one of the possible problem. this PR adds some unittests and fix the problem. Ready to merge. Author: Lee moon soo <leemoonsoo@gmail.com> Author: Lee moon soo <moon@apache.org> Closes #8 from Leemoonsoo/fix/run_order and squashes the following commits: 4a6a230 [Lee moon soo] Prevent status remaining RUNNING after job executed 1fb3715 [Lee moon soo] Fix daedlock 6405abe [Lee moon soo] Update RemoteSchedulerTest c31a807 [Lee moon soo] Make RemoteScheduler keep order of job submitted

This PR addresses https://issues.apache.org/jira/browse/ZEPPELIN-360 Removing "Copyright 2014, NFLabs inc." from LICENSE. Author: Lee moon soo <moon@apache.org> Closes ZEPL#364 from Leemoonsoo/ZEPPELIN-360 and squashes the following commits: cfb814b [Lee moon soo] Remove "Copyright (c) 2010-2015 NFLabs Inc." from NOTICE fb75e86 [Lee moon soo] ZEPPELIN-360 Remove "Copyright 2014, NFLabs inc." from LICENSE

Leemoonsoo added 9 commits February 16, 2015 10:47

Creation of zeppelin-interpreter submodule

36f31fc

structure for remote interpreter using thrift

8b5991d

some interpreter method call implementation

83be346

Remote interpreter implementation

6c8f30b

kill interpreter process when zeppelin-daemon stops

abc78ef

client connection pool

94eb55b

Handle process termination

fae3317

Use className as instance id

cc409e8

Remove unused method

2235c18

Leemoonsoo added 2 commits February 27, 2015 16:43

Run job scheduler on remote process

422a550

graceful shutdown inside of ide (eclipse)

79793e0

Handle output type from remote interpreter process

36ca9ad

Leemoonsoo added 2 commits February 28, 2015 11:00

take care of dynamic form

ffc35c7

setting gui for remote process

07422aa

Leemoonsoo added 4 commits March 1, 2015 07:53

Merge branch 'master' into new/separate_process_interpreter

196c1d5

Conflicts: zeppelin-web/app/scripts/controllers/interpreter.js

Edit remote process mode setting

9a43ee0

Env variable for interpreter process

d7b7289

Fix for checkstyle

8ac0074

Leemoonsoo added 3 commits March 2, 2015 11:58

Refactoring around InterpreterOption

c546abc

Fix dep interpreter

058eb45

Aware of remote mode when interpreter reference each other

ccf6f18

Initialize interpreters in the same group at once so they can referen…

9a083d0

…ce each other.

Fix autocompletion

f3c77e8

Add some doc

39e1217

Remove fork option

78691e8

Fix code style

8aa26e8

Take ZEPPELIN_JAVA_OPTS as default value of ZEPPELIN_INTP_JAVA_OPTS

a3df56a

Leemoonsoo added a commit that referenced this pull request Mar 13, 2015

Merge pull request #364 from NFLabs/new/separate_process_interpreter

6f100f5

Run interpreter on separate JVM

Leemoonsoo merged commit 6f100f5 into master Mar 13, 2015

Leemoonsoo deleted the new/separate_process_interpreter branch March 13, 2015 17:26

Leemoonsoo added a commit that referenced this pull request Mar 15, 2015

Merge pull request #374 from NFLabs/gh-pages_update-interpreter

a81e781

Update documentation for separate interpreter process #364

This was referenced Mar 16, 2015

issue-339: add interpreter jars into classpath #342

Closed

Run sequence is not preserved. #397

Closed

Leemoonsoo mentioned this pull request Mar 28, 2015

Run sequence is not preserved apache/zeppelin#8

Closed

Run interpreter on separate JVM #364

Run interpreter on separate JVM #364

Uh oh!

Conversation

Leemoonsoo commented Feb 26, 2015

Uh oh!

swkimme commented Feb 27, 2015

Uh oh!

Leemoonsoo commented Feb 27, 2015

Uh oh!

swkimme commented Feb 27, 2015

Uh oh!

Leemoonsoo commented Feb 28, 2015

Uh oh!

swkimme commented Mar 1, 2015

Uh oh!

swkimme commented Mar 1, 2015

Uh oh!

swkimme commented Mar 2, 2015

Uh oh!

Leemoonsoo commented Mar 2, 2015

Uh oh!

swkimme commented Mar 11, 2015

Uh oh!

swkimme commented Mar 11, 2015

Uh oh!

swkimme commented Mar 12, 2015

Uh oh!

Leemoonsoo commented Mar 12, 2015

Changes

Uh oh!

swkimme commented Mar 12, 2015

Uh oh!

Leemoonsoo commented Mar 12, 2015

Uh oh!

swkimme commented Mar 12, 2015

Uh oh!

Leemoonsoo commented Mar 13, 2015

Uh oh!

Leemoonsoo commented Mar 13, 2015

Uh oh!

swkimme commented Mar 13, 2015

Uh oh!

Leemoonsoo commented Mar 13, 2015

Uh oh!

jongyoul commented Mar 13, 2015

Uh oh!

jongyoul commented Mar 13, 2015

Uh oh!

Leemoonsoo commented Mar 13, 2015

Uh oh!

jongyoul commented Mar 13, 2015

Uh oh!

swkimme commented Mar 13, 2015

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

4 participants