Update:
Even weirder, I stopped Flink (jobmanager and taskmanager) to increase the
number of slots and, upon restart, it crashed again and then processed
everything just fine.
On Mon, Mar 19, 2018 at 3:01 PM, Julio Biason
wrote:
> Hey guys,
>
> I got a weird problem with my pipeline.
>
> The pi
Hey guys,
I got a weird problem with my pipeline.
The pipeline process lines from our logs and generate different metrics
based on it (I mean, quite the standard procedure). It uses side outputs
for dead letter queues, in case it finds something wrong with the logs and
a metric can't be generated
