Thanks, changing the numerOfTaskSlots did it.
On Thu, 20 Aug 2015 at 15:08 huangwei (G) wrote:
> Hi Aljoscha,
>
> Once, I had the problem like yours.
> What I did is to set the taskmanager.numberOfTaskSlots: 4 in
> conf/flink-conf.yaml since the parallelism of
> StormWordCountRemoteBySubmitter i
Hi Aljoscha,
Once, I had the problem like yours.
What I did is to set the taskmanager.numberOfTaskSlots: 4 in
conf/flink-conf.yaml since the parallelism of StormWordCountRemoteBySubmitter
is 4 by default.
Maybe you can take a try.
BTW: You are right. The StormWordCountLocal gets access in IDEA.
Hi,
I just had a look into this. Currently, not all jars are build
correctly. StormWordCountRemoteBySubmitter is build correctly though.
It starts a program, sleeps for 5 seconds and tries to kill the program
afterwards. The exception you see is "NotAliveException", meaning that
there is no progr
Hi,
I'm afraid submitting the correct program also doesn't work right now. When
I try to execute it I get this:
bin/flink run --jarfile
/Users/aljoscha/Dev/work/flink/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-examples/target/flink-storm-compatibility-examples-0.10-SNAPSHOT-W
Hi Huang,
you are using the wrong jar file. The current built, does not assemble a
jar file for StormWordCountLocal. You can extend pom.xml. Look at the
example StormWordCountRemoteBySubmitter and the corresponding assembly
file word-count-storm.xml.
What you need to do is:
- add a new tag sim
Hi,
could you please try running StormWordCountRemoteBySubmitter instead of
StormWordCountLocal. I think the Local one only works when running inside
an IDE (or executing by hand on the command line). The RemoteBySubmitter
variant should be the correct one for executing on a cluster using
"bin/flin
Hi,
I got some new problems about the storm compatibility currently.
These occurred when I ran the “storm-wordcount” in the storm compatibility on a
flink-0.10SNAPSHOT which I built it over a latest flink project.
First, I start a local flink:
$ cd bin
$ ./start-local.sh
Then I ran the exa
