vineethNaroju commented on PR #4506: URL: https://github.com/apache/zeppelin/pull/4506#issuecomment-1344277755
Thank you Jeff for this patch. The patch worked except one issue - with flink interpreter failed to start with below exception as, ``` Caused by: java.lang.NoClassDefFoundError: org/apache/flink/table/client/util/ClientWrapperClassLoader at java.lang.Class.forName0(Native Method) at java.lang.Class.forName(Class.java:264) at org.apache.zeppelin.flink.FlinkShims.loadShims(FlinkShims.java:71) at org.apache.zeppelin.flink.FlinkShims.getInstance(FlinkShims.java:89) at org.apache.zeppelin.flink.FlinkScalaInterpreter.initFlinkConfig(FlinkScalaInterpreter.scala:158) at org.apache.zeppelin.flink.FlinkScalaInterpreter.open(FlinkScalaInterpreter.scala:122) at org.apache.zeppelin.flink.FlinkInterpreter.open(FlinkInterpreter.java:71) at org.apache.zeppelin.interpreter.LazyOpenInterpreter.open(LazyOpenInterpreter.java:70) ``` The zeppelin's interpreter.sh includes $FLINK_HOME/lib into the flink interpreter class path but it also requires $FLINK_HOME/opt/flink-sql-client*.jar . The below changes in interpreter.sh helped to fix the issue. ``` FLINK_SQL_CLIENT_JAR=$(find "${FLINK_HOME}/opt" -name 'flink-sql-client*.jar') ZEPPELIN_INTP_CLASSPATH+=":${FLINK_PYTHON_JAR}:${FLINK_APP_JAR}:${FLINK_SQL_CLIENT_JAR}" ``` Could you please include this also if it helps ? Please let us know if something is missing from our setup. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: dev-unsubscr...@zeppelin.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org