flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Vinay Patil <vinay18.pa...@gmail.com>
Subject Thread Locals in Flink Streaming Application
Date Fri, 16 Sep 2016 15:50:02 GMT

I am updating the DTO in one operator , so is it safe to use Thread Local
for it, I am taking care to clear it,

My confusion here is : is it required to create a Thread Local variable in
a streaming application, if the same piece of code is executed by different
threads, does flink handles this ?

Can we make use of open method to avoid ThreadLocal by initializing the
variable there, since the open will be called once per thread (correct me

Can you please explain this to make it clear

Vinay Patil

View raw message