That class has been removed as part of
https://issues.apache.org/jira/browse/FLINK-10392 .
The replacement is org.apache.flink.runtime.minicluster.MiniCluster . I
don't know what changes would be required for Zeppelin to work with that.
On 27/05/2019 11:05, Ravi Pullareddy wrote:
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 <mailto:ches...@apache.org>>
*Sent:* Monday, 27 May 2019 6:58 PM
*To:* Ravi Pullareddy <ravi.pullare...@minlog.com.au
<mailto:ravi.pullare...@minlog.com.au>>; user@flink.apache.org
<mailto: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
mailbox:///C:/Programs/Mozilla%20Thunderbird/profile/Mail/Local%20Folders/Apache%20Flink?number=7790&header=quotebody&part=1.2&filename=image001.jpg
Thanks
Ravi
