MiniCluster is there in java code but not in Scala. Zeppelin flink interpreter looks for LocalFlinkMiniCluster class located under scala code org.apache.flink.runtime.minicluster.LocalFlinkMiniCluster
*From:* Chesnay Schepler <ches...@apache.org> *Sent:* Monday, 27 May 2019 6:58 PM *To:* Ravi Pullareddy <ravi.pullare...@minlog.com.au>; user@flink.apache.org *Subject:* Re: Minicluster missing in scala runtime in version 1.8 source code It's still there: https://github.com/apache/flink/tree/release-1.8/flink-runtime/src/main/java/org/apache/flink/runtime/minicluster Please provide more details on what you believe to be missing. On 27/05/2019 01:02, Ravi Pullareddy wrote: Hi There I notice mini cluster folder missing under scala runtime in version 1.8. I am able to compile version 1.7 for zeppelin interpreter but not flink version 1.8. Is there a way to compile scala interpreter in zeppelin for version 1.8 [image: cid:image001.jpg@01D514BE.DF9E1A40] Thanks Ravi
