I have an Apache Beam pipeline written on Java. I'm with a problem that
some routines are not being executed on all instances of that pipeline.

Those routines are as simple as logging messages or excluding a file in
GCS. They are all put to run after the following code:

More at
https://stackoverflow.com/questions/49328973/routines-intermittently-not-being-executed-on-apache-beam-code

Best,

-- 
*Lucas Arruda*

Reply via email to