Uploaded image for project: 'Zeppelin'
  1. Zeppelin
  2. ZEPPELIN-3028

not able to run flink class

    XMLWordPrintableJSON

    Details

    • Type: Test
    • Status: Open
    • Priority: Blocker
    • Resolution: Unresolved
    • Affects Version/s: None
    • Fix Version/s: None
    • Component/s: build
    • Labels:
      None

      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.

        Attachments

        1. Error.png
          71 kB
          ajinkya mahakalkar

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              ajinkyamahakalkar ajinkya mahakalkar
            • Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

              • Created:
                Updated: