Struggling with logging on Flink on kubernetes

Been scratching my head trying to figure out why flink logs every log I put in my Main class but silently ignores any kind of logging I put on `RichSinkFunction` or my `DeserializationSchema` implementation

Posted Jul 6, 2023, 4:58 PM UTC

10
Loading comments…