GitHub user astroshim reopened a pull request:
https://github.com/apache/zeppelin/pull/1922
[ZEPPELIN-1991] Can't get the PARAGRAPH_APPEND_OUTPUT from the Interpreter.
### What is this PR for?
This PR fixes the problem of streaming events(PARAGRAPH_APPEND_OUTPUT).
It's because of the queue was not thread safe.
### What type of PR is it?
Bug Fix
### What is the Jira issue?
https://issues.apache.org/jira/browse/ZEPPELIN-1991
### How should this be tested?
1. make a spark paragraph
2. run following code on spark paragraph.
```
%spark
(1 to 5).foreach{ i=>
Thread.sleep(1000)
println("Hello " + i)
}
```
3. make a python paragraph
4. run following code on python paragraph.
```
%python.python
print("hi1")
```
5. retry run step 2, and check if streaming working.
### Screenshots (if appropriate)
- before
- after
### Questions:
* Does the licenses files need update? no
* Is there breaking changes for older versions? no
* Does this needs documentation? no
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/astroshim/zeppelin ZEPPELIN-1991
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/zeppelin/pull/1922.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #1922
----
commit 66d3d2fef536f27d6e21bf74f901618c021c0aa7
Author: astroshim <hss...@zepl.com>
Date: 2017-01-20T21:41:01Z
fix to thread safe
commit e99358541c23bd0cefe5e3dbd2eb7d96890a0ab0
Author: astroshim <hss...@zepl.com>
Date: 2017-01-21T00:18:40Z
make scheduler not static
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
