[jira] [Created] (ZEPPELIN-3028) not able to run flink class

[ajinkya mahakalkar (JIRA)]

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)