Thanks Rong!. The UDF makes a http call to another service synchronously.
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
According to the codegen result, I think each field is invoked
sequentially.
However, if you maintain internal state within your UDF, it is your
responsibility to maintain the internal state consistency.
Are you invoking external RPC in your "GetName" UDF method and that has to
be async?
--
Rong
Thanks Hequn!. Is it also thread safe when the same UDF is called multiple
times in the same record.
Is the UDF called sequentially for each fields a single record, I have a
query like -
select GetName(data.id, 'city'), GetName(data.id, 'zone') from ..
--
Sent from:
Hi Anil,
It is thread-safe.
Each udf instance will only run in one task. And for each udf, it processes
data synchronously, i.e, the next record will not be processed until the
current record is processed.
Best, Hequn
On Sat, Jan 12, 2019 at 3:12 AM Anil wrote:
> Is the eval method invoked in
