Hi Ken,
Never mind. I did a map of Tuple2.of(C, 1) -> Tuple2.of(F, 1) before
keyBy, then replaced the map after sum with Tuple2.of(F, ) -> d . I
got the expected result. So it's very likely something is wrong with C in
determining equalness. Thank you all the same.
- Luke
On Sun, Apr 30, 2023
Hi Luke,
Without more details, I don’t have a good explanation for why you’re seeing
duplicate results.
— Ken
> On Apr 29, 2023, at 7:38 PM, Luke Xiong wrote:
>
> Hi Ken,
>
> My workflow looks like this:
>
> dataStream
> .map(A -> B)
> .flatMap(B -> some Tuple2.of(C, 1))
> .keyB
