Hi everyone,
I want to develop a custom task scheduler in Flink, specifically, I want to
control the scheduling of components of an topology into specific hosts, where
should I start with? Is there an example program or tutorial about this? Thanks!
Thanks.
Best regards.
Shuhao Zhang (Tony)
compatibility layer does not properly configure the Local
Flink Executor to have the right parallelism.
In 1.0 that is fixed. If you try the latest snapshot, or the
1.0-Release-Candidate-1, it should work.
Greetings,
Stephan
On Fri, Feb 26, 2016 at 12:16 PM, #ZHANG SHUHAO#
<szh
ber of slots in the flink-conf.yaml file.
Cheers,
Till
On Fri, Feb 26, 2016 at 10:34 AM, #ZHANG SHUHAO#
<szhang...@e.ntu.edu.sg<mailto:szhang...@e.ntu.edu.sg>> wrote:
Hi everyone,
I’m a student researcher working on Flink recently.
I’m trying out the flink-storm example project
Hi everyone,
I'm a student researcher working on Flink recently.
I'm trying out the flink-storm example project, version 0.10.2,
flink-storm-examples, word-count-local.
But, I got the following error:
org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException: Not
enough free
