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*