flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From <jacopo.go...@ubs.com>
Subject RE: Flink's Either type information
Date Wed, 19 Feb 2020 17:07:20 GMT
Yes, I create it the way you mentioned.

From: Yun Gao [mailto:yungao.gy@aliyun.com]
Sent: Dienstag, 18. Februar 2020 10:12
To: Gobbi, Jacopo-XT; user
Subject: [External] Re: Flink's Either type information

      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?


From:jacopo.gobbi <jacopo.gobbi@ubs.com>
Send Time:2020 Feb. 17 (Mon.) 18:31
To:user <user@flink.apache.org>
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,


Jacopo Gobbi

View raw message