1

In every specific Flink app I can use whatever logger (logback, log4j2, etc.) with appropriate configuration.

But in standalone mode, the actual configuration used is not the one in my jar file because Flink has it own configuration files (log4j2 by default), which take precedence over my own.

The goal is to pass job name (not jobId) to my logs like this:

10/06/2023 21:05:22.527[my-flink-application-0.1.3] INFO [org.example.service.MainSourceFunction] : Hello world

Is there any best way to do this?

0

0

Your Answer

By clicking “Post Your Answer”, you agree to our terms of service and acknowledge you have read our privacy policy.

Start asking to get answers

Find the answer to your question by asking.

Ask question

Explore related questions

See similar questions with these tags.