Search code examples
javaapache-flinkflink-streaming

Does processElement() block broadcastProcessElement()?


I know that when broadcastProcessElement() is executing, processElement will not be executed, but is the vice versa also true?


Solution

  • Yes. There’s a single thread for executing all of the user-implemented methods in the same task.