Flink SQL .print() to logs

2024-12-30 Thread Yarden BenMoshe
Hi all, I am new to flink sql and having trouble understanding how to debug my code. I wish to use some kind of a print function to see the output from my queries in the pipeline's logs. Below there's a pipeline similar to the one i am using, which integrates with kafka and sends an avro message as

[Flink kubernetes operator] custom dependent resources?

2024-12-22 Thread Yarden BenMoshe
Hi all, I am currently using Flink via Kubernetes Operator and looking to connect my Flink pipeline to Prometheus for metrics. To do so, I thought of creating a headless service and exposing a specific port (for example 9249, Flink's default). I wish to automate the creation of the service to be