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

Reply via email to