ajinkya mahakalkar created ZEPPELIN-3028:
--------------------------------------------
Summary: not able to run flink class
Key: ZEPPELIN-3028
URL: https://issues.apache.org/jira/browse/ZEPPELIN-3028
Project: Zeppelin
Issue Type: Test
Components: build
Reporter: ajinkya mahakalkar
Priority: Blocker
Hi,
I have built a sample main class which calls the flink adapter on Zeppelin and
created a fat jar out of the code.
The modules that I have included while building are:
Zeppelin
interpreter
Zeppelin: Flink
Zeppelin: Flink module has a main class named as SampleMain which calls the
FlinkInterpreter.java and opens a connection with Flink and executes a flink
code.
SampleMain.java
package org.apache.zeppelin.flink;
import org.apache.zeppelin.interpreter.InterpreterContext;
import org.apache.zeppelin.interpreter.InterpreterResult;
import java.util.Properties;
public class SampleMain {
public static void main(String args[]){
FlinkInterpreter flink;
InterpreterContext context;
Properties p = new Properties();
flink = new FlinkInterpreter(p);
flink.open();
context = new InterpreterContext(null, null, null, null, null, null, null,
null,
null, null, null, null);
InterpreterResult result = flink.interpret("val a=1", context);
result = flink.interpret("print(a)", context);
System.out.println(result.message().get(0).getData());
}
}
After building this jar, I am running the jar (using java -cp ) where zeppelin
is installed and running.
Cmd: java -cp zeppelin-flink_2.10-0.8.0-SNAPSHOT-jar-with-dependencies.jar
org.apache.zeppelin.flink.SampleMain
I am getting the following error:
Exception in thread "main" java.lang.RuntimeException: Could not start Flink
mini cluster.
at
org.apache.zeppelin.flink.FlinkInterpreter.startFlinkMiniCluster(FlinkInterpreter.java:399)
at
org.apache.zeppelin.flink.FlinkInterpreter.open(FlinkInterpreter.java:85)
at org.apache.zeppelin.flink.SampleMain.main(SampleMain.java:18)
Caused by: com.typesafe.config.ConfigException$Missing: No configuration
setting found for key 'akka.remote.log-received-messages'
at com.typesafe.config.impl.SimpleConfig.findKey(SimpleConfig.java:124)
at com.typesafe.config.impl.SimpleConfig.find(SimpleConfig.java:145)
at com.typesafe.config.impl.SimpleConfig.find(SimpleConfig.java:151)
Please tell me what else changes do I need to make in the code to make this
work.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
