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)
+65-
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#
mailto:szhang
k-conf.yaml file.
Cheers,
Till
On Fri, Feb 26, 2016 at 10:34 AM, #ZHANG SHUHAO#
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, version 0.10.2,
flink-storm-examples, word-count-l
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 s
