Streaming error, StockPrices example

classic Classic list List threaded Threaded
4 messages Options
Reply | Threaded
Open this post in threaded view
|

Streaming error, StockPrices example

subashbasnet
Hello all,

The StockPrices.java example of the given link, 
StreamingExamples
shows error due to lack of SourceContext class in the provided flink-streaming-core jar as given in maven. 


So I added another dependency as below in maven:
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-streaming-core</artifactId>
<version>0.9.0</version>
</dependency>

Now the SourceContext is found, but shows @override error in the inner class StockSource.



Best Regards,
Subash Basnet

Reply | Threaded
Open this post in threaded view
|

Re: Streaming error, StockPrices example

Ufuk Celebi
Hey Subash! The example is not part of the Flink distribution (any more). Probably you are running into a version mismatch. The examples packages you are referring to actually sets up all dependencies. How are you trying to run this?

On Sat, May 14, 2016 at 3:03 PM, subash basnet <[hidden email]> wrote:
Hello all,

The StockPrices.java example of the given link, 
StreamingExamples
shows error due to lack of SourceContext class in the provided flink-streaming-core jar as given in maven. 


So I added another dependency as below in maven:
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-streaming-core</artifactId>
<version>0.9.0</version>
</dependency>

Now the SourceContext is found, but shows @override error in the inner class StockSource.



Best Regards,
Subash Basnet


Reply | Threaded
Open this post in threaded view
|

Re: Streaming error, StockPrices example

subashbasnet
In reply to this post by subashbasnet
Hello Ufuk,

Yeah I had tried running the examples via eclipse, yeah it should have setup all dependencies but no it doesn't. It shows error with regard to SourceContext not available as explained via image in earlier thread. 
So I had to add this new depedency in maven to get rid of SourceContext not available error as below:

<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-streaming-core</artifactId>
<version>0.9.0</version>
</dependency>

But after adding this dependency the previous SourceContext error get's removed but now another new @override error occurs inside the inner class StockSource, the image of error is attached earlier. 


Best Regards,
Subash Basnet

On Fri, May 20, 2016 at 12:16 PM, Ufuk Celebi <[hidden email]> wrote:
Boxbe This message is eligible for Automatic Cleanup! ([hidden email]) Add cleanup rule | More info

Hey Subash! The example is not part of the Flink distribution (any more). Probably you are running into a version mismatch. The examples packages you are referring to actually sets up all dependencies. How are you trying to run this?

On Sat, May 14, 2016 at 3:03 PM, subash basnet <[hidden email]> wrote:
Hello all,

The StockPrices.java example of the given link, 
StreamingExamples
shows error due to lack of SourceContext class in the provided flink-streaming-core jar as given in maven. 


So I added another dependency as below in maven:
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-streaming-core</artifactId>
<version>0.9.0</version>
</dependency>

Now the SourceContext is found, but shows @override error in the inner class StockSource.



Best Regards,
Subash Basnet




Reply | Threaded
Open this post in threaded view
|

Re: Streaming error, StockPrices example

Stephan Ewen
Hi!

Still sounds like a version mixup in your dependencies, or the IDE did not properly pick up the changes (re-import / refresh).

On Wed, May 25, 2016 at 5:32 PM, subash basnet <[hidden email]> wrote:
Hello Ufuk,

Yeah I had tried running the examples via eclipse, yeah it should have setup all dependencies but no it doesn't. It shows error with regard to SourceContext not available as explained via image in earlier thread. 
So I had to add this new depedency in maven to get rid of SourceContext not available error as below:

<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-streaming-core</artifactId>
<version>0.9.0</version>
</dependency>

But after adding this dependency the previous SourceContext error get's removed but now another new @override error occurs inside the inner class StockSource, the image of error is attached earlier. 


Best Regards,
Subash Basnet

On Fri, May 20, 2016 at 12:16 PM, Ufuk Celebi <[hidden email]> wrote:
Boxbe This message is eligible for Automatic Cleanup! ([hidden email]) Add cleanup rule | More info

Hey Subash! The example is not part of the Flink distribution (any more). Probably you are running into a version mismatch. The examples packages you are referring to actually sets up all dependencies. How are you trying to run this?

On Sat, May 14, 2016 at 3:03 PM, subash basnet <[hidden email]> wrote:
Hello all,

The StockPrices.java example of the given link, 
StreamingExamples
shows error due to lack of SourceContext class in the provided flink-streaming-core jar as given in maven. 


So I added another dependency as below in maven:
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-streaming-core</artifactId>
<version>0.9.0</version>
</dependency>

Now the SourceContext is found, but shows @override error in the inner class StockSource.



Best Regards,
Subash Basnet