[jira] [Created] (ZEPPELIN-3079) Flink Interpreter Error

[ajinkya mahakalkar (JIRA)]

ajinkya mahakalkar created ZEPPELIN-3079:
--------------------------------------------

             Summary: Flink Interpreter Error
                 Key: ZEPPELIN-3079
                 URL: https://issues.apache.org/jira/browse/ZEPPELIN-3079
             Project: Zeppelin
          Issue Type: Bug
            Reporter: ajinkya mahakalkar


Hi,

I am trying to run flink interpreter but getting error.
I have attached the complete log.
Can somebody tell me what configurations values are required to start a flink 
mini local cluster.
Currently, I have the following configurations in my code:
flinkConf = new org.apache.flink.configuration.Configuration();
            flinkConf.setInteger(ConfigConstants.LOCAL_NUMBER_TASK_MANAGER, 2);
            flinkConf.setInteger(ConfigConstants.TASK_MANAGER_NUM_TASK_SLOTS, 
3);
            
//flinkConf.setString(ConfigConstants.DEFAULT_EXECUTION_RETRY_DELAY_KEY, "0 
ms");
            flinkConf.setInteger(ConfigConstants.TASK_MANAGER_MEMORY_SIZE_KEY, 
12);
            flinkConf.setString(ConfigConstants.AKKA_CLIENT_TIMEOUT,"1 min");
            
flinkConf.setString(ConfigConstants.JOB_MANAGER_IPC_ADDRESS_KEY,"localhost");
            flinkConf.setInteger(ConfigConstants.JOB_MANAGER_IPC_PORT_KEY,6123);
            flinkConf.setInteger(ConfigConstants.JOB_MANAGER_WEB_PORT_KEY,8081);
            flinkConf.setString(JobManagerOptions.ADDRESS,"localhost");
localFlinkCluster = new LocalFlinkMiniCluster(flinkConf,false);

 flinkIloop = new 
FlinkILoop("10.76.165.32",localFlinkCluster.getLeaderRPCPort(),
                    flinkConf, Option.<String[]>empty(),
                    (BufferedReader) null, new PrintWriter(out));




--
This message was sent by Atlassian JIRA
(v6.4.14#64029)