Hi Jacopo,
Could you also provide how the KeyedBroadcastProcessFunction is
created when constructing datastream API ? For example, are you using something
like
new KeyedBroadcastProcessFunction<Integer, Integer, Integer,
Either<MyLeft, MyRight>() {
// Function implementation
}
or something else?
Best,
Yun
------------------------------------------------------------------
From:jacopo.gobbi <[email protected]>
Send Time:2020 Feb. 17 (Mon.) 18:31
To:user <[email protected]>
Subject:Flink's Either type information
Hi all,
How can an Either value be returned by a KeyedBroadcastProcessFunction?
We keep getting "InvalidTypesException: Type extraction is not possible on
Either type as it does not contain information about the 'left' type." when
doing: out.collect(Either.<MyLeftType, MyRightType>Right(myObject));
Thanks,
Jacopo Gobbi
