Minicluster missing in scala runtime in version 1.8 source code

[Ravi Pullareddy]

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

 

 

 

Thanks

 

Ravi

 

[Chesnay Schepler]

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

 

 

 

Thanks

 

Ravi

 

[Ravi Pullareddy]

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 <[hidden email]>
Sent: Monday, 27 May 2019 6:58 PM
To: Ravi Pullareddy <[hidden email]>; [hidden email]
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

 

 

 

Thanks

 

Ravi

 

 

[Chesnay Schepler]

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 <[hidden email]>
Sent: Monday, 27 May 2019 6:58 PM
To: Ravi Pullareddy <[hidden email]>; [hidden email]
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

 

 

 

Thanks

 

Ravi