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.Right(myObject));
Thanks,
Jacopo Gobb
Yes, I create it the way you mentioned.
From: Yun Gao [mailto:yungao...@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
Hi all,
Yes my problem is that I do not create the function inline but create a
function directly when creating the data stream job.
My code (which I cannot share) is exactly like your example, Yun, are you aware
if there is a way to prevent code erasure?
Kind regards,
Jacopo Gobbi
From: Yun
Hi all,
I was wondering if anybody has any recommendation over making HTTP requests
from Flink to another service.
On the long term we are looking for a solution that is both performing and
integrates well with our flink program.
Does it matter the library we use? Do we need a special connector
Hi,
I have a flink program which needs to process many messages and part of this
processing is to process the data using an external web service using http
calls.
Example:
val myStream: DataStream[String]
myStream
.map(new MyProcessingFunction)
.map(new MyWebServiceHttpClient)
.print
Any s
Hi all,
I was wondering if anybody has anybody made a connector (Source) to be used
with IBM MQ?
Also if somebody could point me to any doc on how to write a custom connector,
it would be appreciated.
We are using Scala 2.12 and Flink 1.7.
Kind regards,
Jacopo Gobbi
Visit our website at http:
