score:3

Accepted answer

thanks for comments from harald and others, i found out a couple of things, which led me to achieve normal processing behaviour -

  1. test code with local mode, yarn isnt the biggest help in debugging
  2. for some reason, the process method of foreach sink doesnt allow calling other methods. when i put my business logic directly in there, it works.

hope it helps others.


Related Query

More Query from same tag