Hello Everyone,
I was wondering if anyone could help shed light on where I have introduced
an error into my code to get the following error:
java.lang.NullPointerException
at java.lang.String.(String.java:556)
at
org.apache.flink.streaming.util.serialization.SimpleStringSchema.des
Hi Shaosu,
Do you have an estimate on the total size of state you are keeping for the
windows? How many messages/sec, how large a window, message size, etc
would be good details to include.
Also, which state backend are you using? Have you considered using the
RocksDB state backend. This backe
I got the same error with this commit too. Weird :-( I will try picking the
necessary classes. Thanks anyway.
On Sat, Sep 3, 2016 at 7:41 AM, Robert Metzger wrote:
> I also can't checkout the commit locally... which is weird, because GitHub
> still seems to be able to somehow access it.
>
> Can
I also can't checkout the commit locally... which is weird, because GitHub
still seems to be able to somehow access it.
Can you try this commit: df42160832ff65ae2a85b478d1dd0b398fa6ef3f ?
I actually believe its probably easier to just pick the classes you need
from the "benchmark" repository and
Hi all,
It turns out that there were other factors influencing my performance tests.
(actually hbase)Hence, more consumers than partitions in Flink was not the
problem. Thanks for the help!
On Wednesday, August 3, 2016 5:42 PM, neo21 zerro
wrote:
Hello,
I've tried to increase the ne
Hi,
the memory management described in this wiki page only applies to the batch
api. The streaming api currently uses the Java heap, but we are strongly
considering introducing managed memory for streaming as well.
Best,
Stefan
> Am 02.09.2016 um 22:45 schrieb Shaosu Liu :
>
> Hi,
>
> I have
