[ZEPPELIN-3028] not able to run flink class

• Type: Test
• Status: Open
• Priority: Blocker
• Resolution: Unresolved
• Component/s: build
• Assignee: Unassigned
• Reporter: ajinkya mahakalkar
• Created: 03/Nov/17 10:31
• Updated: 03/Nov/17 10:32

Description

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.