eventually anyway since I'm planning to
contribute to Flink.
Cheers,
Dan
On Mon, Sep 14, 2015 at 3:01 PM, Daniel Blazevski <
daniel.blazev...@gmail.com> wrote:
> Thanks for the feedback.
>
> I have another question about building using sbt: how can one go from
> import sta
ou can add the Apache Snapshot
>> repository, in sbt:
>> resolvers += "apache-snapshot" at "
>> https://repository.apache.org/content/repositories/snapshots/“
>> It would probably be better to use scala 2.10 rather than 2.9.
>>
>> Giancarlo
>
error message is no longer popping up.
Dan
On Sun, Sep 13, 2015 at 3:53 PM, Daniel Blazevski <
daniel.blazev...@gmail.com> wrote:
> Hello,
>
> Earlier today, I was able to get a Flink cluster running, and successfully
> ran the wordcount jar file in the examples folder.
>
Hello,
Earlier today, I was able to get a Flink cluster running, and successfully
ran the wordcount jar file in the examples folder.
I then tried to compile the WordCount example using sbt found here:
https://ci.apache.org/projects/flink/flink-docs-master/quickstart/scala_api_quickstart.html#alte
the cluster, and the example runs (even w/o the -p
1 setting)
Best,
Dan
On Sun, Sep 13, 2015 at 10:40 AM, Daniel Blazevski <
daniel.blazev...@gmail.com> wrote:
> Hello,
>
> I am new to Flink, I setup a Flink cluster on 4 m4.large Amazon EC2
> instances, and set the following
Hello,
I am new to Flink, I setup a Flink cluster on 4 m4.large Amazon EC2 instances,
and set the following in link-conf.yaml:
jobmanager.heap.mb: 4000
taskmanager.heap.mb: 5000
taskmanager.numberOfTaskSlots: 2
parallelism.default: 8
In the 8081 dashboard, it shows 4 for Task Manager and 5 for
