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)
