I would also keep an eye on this issue from the Zeppelin project:
https://issues.apache.org/jira/browse/ZEPPELIN-44
The needed infrastructure is going to be very similar
On Thu, Apr 16, 2015 at 10:15 AM, Kostas Tzoumas
wrote:
> Great, let us know if you run into any issues.
>
> Can you create a
Great, let us know if you run into any issues.
Can you create a JIRA on the REPL and link to your repository for the
community to track the status?
On Wed, Apr 15, 2015 at 4:23 PM, Nikolaas s
wrote:
> Thanks for the feedback guys!
> Apparently The Scala Shell compiles the Shell input to some ki
Thanks for the feedback guys!
Apparently The Scala Shell compiles the Shell input to some kind of virtual
directory.
It should be possible to create a jar from it's content and then hand it
over to Flink for execution in some way.
I will further investigate..
cheers,
Nikolaas
2015-04-15 11:20 GMT
To give a bit of context for the exception:
To execute a program, the classes of the user functions need to be
available the executing TaskManagers.
- If you execute locally from the IDE, all classes are in the classpath
anyways.
- If you use the remote environment, you need to attach the jar f
I will look into it once I have some time (end of this week, or next
week probably)
On Tue, Apr 14, 2015 at 8:51 PM, Robert Metzger wrote:
> Hey Nikolaas,
>
> Thank you for posting on the mailing list. I've met Nikolaas today in
> person and we were talking a bit about an interactive shell for Fl
Hey Nikolaas,
Thank you for posting on the mailing list. I've met Nikolaas today in
person and we were talking a bit about an interactive shell for Flink,
potentially also an integration with Zeppelin.
Great stuff I'm really looking forward to :)
We were wondering if somebody from the list has s
Hi!
I am trying to implement a scala shell for flink.
I've started with a simple scala object who's main function will drop the
user to the interactive scala shell (repl) at one point:
import scala.tools.nsc.interpreter.ILoop
import scala.tools.nsc.Settings
object Job {
def main(args: Array
