Login  Register

subtasks and objects

classic Classic list List threaded Threaded
2 messages Options Options
Embed post
Permalink
Reply | Threaded
Open this post in threaded view
| More
Print post
Permalink

subtasks and objects

Stavros Kontopoulos
Hey,

Is it true that since taskmanager (a jvm) may have multiple subtasks
implementing the same operator and thus same logic and loading the same classes, no separating classloading is done right?
So if i use a scala object or static code as in java within that logic then that is shared among the tasks and synchronization is needed?

Best,
Stavros
Reply | Threaded
Open this post in threaded view
| More
Print post
Permalink

Re: subtasks and objects

Aljoscha Krettek
Hi,
I think this is correct, yes. It is probably not a good idea to use static code in Flink jobs.

Cheers,
Aljoscha

On Wed, 25 May 2016 at 00:27 Stavros Kontopoulos <[hidden email]> wrote:
Hey,

Is it true that since taskmanager (a jvm) may have multiple subtasks
implementing the same operator and thus same logic and loading the same classes, no separating classloading is done right?
So if i use a scala object or static code as in java within that logic then that is shared among the tasks and synchronization is needed?

Best,
Stavros