ajinkya mahakalkar created ZEPPELIN-3074:
--------------------------------------------
Summary: Flink Interpreter Error
Key: ZEPPELIN-3074
URL: https://issues.apache.org/jira/browse/ZEPPELIN-3074
Project: Zeppelin
Issue Type: Bug
Reporter: ajinkya mahakalkar
Priority: Blocker
Hi,
I am trying to pass a flink code through java thrift client.
While sending the flink code through client using thrift, the server is
throwing the following error:
org.apache.flink.client.program.ProgramInvocationException: Could not start the
ActorSystem needed to talk to the JobManager.
also, imain.interpret() method is throwing error on println() statements.
My client code is also in Java and I am passing the flink code as a string.
The code i am trying to pass is as follows:
String flinkCode3="val data = List(\"hi\",\"how are you\",\"hi\")\n" +
"val dataSet = benv.fromCollection(data)\n" +
"val words = dataSet.flatMap(value =>
value.split(\"\\\\s+\"))\n" +
"val mappedWords = words.map(value => (value,1))\n" +
"val grouped = mappedWords.groupBy(0)\n" +
"val sum = grouped.sum(1)\n" +
"println(sum.collect())\n";
Every line from the above get is returning success code except for the last
line.
Is there anything i am doing wrong or is there any setting/config that i need
to set?
As I am not able to post this error in the mailing list, I am posting it here.
Request your help in resolving this as soon as possible.
appreciate your help.
Thank you
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
