You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by Stavros Kontopoulos <st...@gmail.com> on 2016/05/24 22:27:47 UTC
subtasks and objects
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
Re: subtasks and objects
Posted by Aljoscha Krettek <al...@apache.org>.
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 <st...@gmail.com>
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
>