This is a pretty simple pattern, as in I hardly have 1500 elements (
across 600 keys at the max ) put in
and though I have a pretty wide range , as in I am looking at a
relaxed pattern ( like 40 true conditions in 6 hours ),
I get this. I have the EventTime turned on.
java.lang.OutOfMemoryError: Java heap space
at java.util.Arrays.copyOf(Arrays.java:3332)
at
java.lang.AbstractStringBuilder.ensureCapacityInternal(AbstractStringBuilder.java:124)
at
java.lang.AbstractStringBuilder.append(AbstractStringBuilder.java:448)
at java.lang.StringBuilder.append(StringBuilder.java:136)
at java.lang.StringBuilder.append(StringBuilder.java:131)
at org.apache.commons.lang3.StringUtils.join(StringUtils.java:4106)
at org.apache.commons.lang3.StringUtils.join(StringUtils.java:4151)
at
org.apache.flink.cep.nfa.SharedBuffer$SharedBufferEntry.toString(SharedBuffer.java:624)
at java.lang.String.valueOf(String.java:2994)
at java.lang.StringBuilder.append(StringBuilder.java:131)
at
org.apache.flink.cep.nfa.SharedBuffer$SharedBufferSerializer.serialize(SharedBuffer.java:964)
at
org.apache.flink.cep.nfa.SharedBuffer$SharedBufferSerializer.serialize(SharedBuffer.java:835)
at org.apache.flink.cep.nfa.NFA$NFASerializer.serialize(NFA.java:888)
at org.apache.flink.cep.nfa.NFA$NFASerializer.serialize(NFA.java:820)
at
org.apache.flink.contrib.streaming.state.RocksDBValueState.update(RocksDBValueState.java:100)
.
.
.
Any one has seen this issue ?
