Log rollover for logs.

[John Smith]

Hi, I'm running flink as a systemd service with...

[Service]
Type=forking
WorkingDirectory=/opt/flink
User=flink
Group=flink
ExecStart=/opt/flink/bin/taskmanager.sh start
ExecStop=/opt/flink/bin/taskmanager.sh stop
TimeoutSec=30
Restart=on-failure

My log4j.porperties file is at /opt/flink/conf

Is it as simple as just setting the log rollover in there? Cause sometimes with certain services like zookeeper some env variable overrides etc... So just wondering if it's that straight forward with flink.

[Nicolaus Weidner]

Hi John,

On Tue, Apr 27, 2021 at 9:47 AM John Smith <[hidden email]> wrote:

Hi, I'm running flink as a systemd service with...

[Service]
Type=forking
WorkingDirectory=/opt/flink
User=flink
Group=flink
ExecStart=/opt/flink/bin/taskmanager.sh start
ExecStop=/opt/flink/bin/taskmanager.sh stop
TimeoutSec=30
Restart=on-failure

My log4j.porperties file is at /opt/flink/conf

Is it as simple as just setting the log rollover in there? Cause sometimes with certain services like zookeeper some env variable overrides etc... So just wondering if it's that straight forward with flink.

yes, you can use the log4j RollingFileAppender [1] for this purpose. You can also find more information regarding logging in Flink in the docs [2]. 

Best regards,

Nico

[1] https://logging.apache.org/log4j/2.x/manual/appenders.html#RollingFileAppender

[2] https://ci.apache.org/projects/flink/flink-docs-stable/deployment/advanced/logging.html