Is the method called multiple times with different input sets?
Does the issue occur regardless of which uid you set?
On 03.05.2017 20:21, Rami Al-Isawi wrote:
Hi,
Nope, that is the only uid in the whole project. The
“userRawDataStream" comes from a splitter:
public static class
Hi,
Nope, that is the only uid in the whole project. The “userRawDataStream" comes
from a splitter:
public static class Splitter implements OutputSelector{
@Override
public Iterable select(EventRaw value) {
List output = new ArrayList<>();
output.add(value.type);
Hello,
was a uid set on "userRawDataStream", or any of it's parent transformations?
On 03.05.2017 12:59, Rami Al-Isawi wrote:
Hi,
I am trying to set uids. I keep getting this (Flink.1.2):
Exception in thread "main" java.lang.IllegalArgumentException: Hash
collision on user-specified ID.
Hi,
I am trying to set uids. I keep getting this (Flink.1.2):
Exception in thread "main" java.lang.IllegalArgumentException: Hash collision
on user-specified ID. Most likely cause is a non-unique ID. Please check that
all IDs specified via `uid(String)` are unique.
Here is the code snippet.
