Hi,
it is 2 days i am going mad with a problem, every time i run the code (on the
same dataset) i get a different result
while i was trying debugging i found this
i have this code
val aggregationResult = //something that creates the dataset and uses join,
group, reduce and map
logger.error("res count " + aggregationResult.count)
aggregationResult.print
the logger prints a dataset size of 7
the output result is made of 6 elements
this happens randomly sometimes the result is larger than the count and
sometimes they are both correct at 10
flink version 0.9milestone1
any idea of what can make it “not deterministic”?
thanks for help
