You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by "casel.chen" <ca...@126.com> on 2021/07/09 12:28:39 UTC

flink on native k8s要如何动态改变日志配置?

flink运行在原生k8s上,现在想要修改Root Logger Level和动态添加 Logger Name -> Logger Level,以及用户可以传入自定义的日志模板,目前有办法做到么?

Re: Re:Re: flink on native k8s要如何动态改变日志配置?

Posted by Yang Wang <da...@gmail.com>.
运行在session内的任务日志无法独立配置
除非是你每个任务的用户代码package都不一样,在log4j中配置不同的package写入不同的文件。但Flink框架日志还是无法区分

Best,
Yang

东东 <do...@163.com> 于2021年7月13日周二 下午12:56写道:

> 是的,日志配置是针对JM和TM的
>
>
>
>
>
> 在 2021-07-13 12:37:20,"casel.chen" <ca...@126.com> 写道:
> >如果是 session
> mode的话,日志配置文件是对整个session上运行的作业都生效么?每个运行在session上的作业可以独立配置日志吗?谢谢!
> >
> >
> >
> >
> >
> >
> >
> >
> >
> >
> >
> >
> >
> >
> >
> >
> >
> >在 2021-07-12 10:57:08,"Yang Wang" <da...@gmail.com> 写道:
> >>你直接修改ConfigMap中存储的log4j-console.properties就可以立即生效了,具体参考这里[1]
> >>
> >>[1].
> >>
> https://ci.apache.org/projects/flink/flink-docs-master/docs/deployment/resource-providers/native_kubernetes/#changing-the-log-level-dynamically
> >>
> >>Best,
> >>Yang
> >>
> >>casel.chen <ca...@126.com> 于2021年7月9日周五 下午8:29写道:
> >>
> >>> flink运行在原生k8s上,现在想要修改Root Logger Level和动态添加 Logger Name -> Logger
> >>> Level,以及用户可以传入自定义的日志模板,目前有办法做到么?
>

Re:Re:Re: flink on native k8s要如何动态改变日志配置?

Posted by 东东 <do...@163.com>.
是的,日志配置是针对JM和TM的





在 2021-07-13 12:37:20,"casel.chen" <ca...@126.com> 写道:
>如果是 session mode的话,日志配置文件是对整个session上运行的作业都生效么?每个运行在session上的作业可以独立配置日志吗?谢谢!
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>在 2021-07-12 10:57:08,"Yang Wang" <da...@gmail.com> 写道:
>>你直接修改ConfigMap中存储的log4j-console.properties就可以立即生效了,具体参考这里[1]
>>
>>[1].
>>https://ci.apache.org/projects/flink/flink-docs-master/docs/deployment/resource-providers/native_kubernetes/#changing-the-log-level-dynamically
>>
>>Best,
>>Yang
>>
>>casel.chen <ca...@126.com> 于2021年7月9日周五 下午8:29写道:
>>
>>> flink运行在原生k8s上,现在想要修改Root Logger Level和动态添加 Logger Name -> Logger
>>> Level,以及用户可以传入自定义的日志模板,目前有办法做到么?

Re:Re: flink on native k8s要如何动态改变日志配置?

Posted by "casel.chen" <ca...@126.com>.
如果是 session mode的话,日志配置文件是对整个session上运行的作业都生效么?每个运行在session上的作业可以独立配置日志吗?谢谢!

















在 2021-07-12 10:57:08,"Yang Wang" <da...@gmail.com> 写道:
>你直接修改ConfigMap中存储的log4j-console.properties就可以立即生效了,具体参考这里[1]
>
>[1].
>https://ci.apache.org/projects/flink/flink-docs-master/docs/deployment/resource-providers/native_kubernetes/#changing-the-log-level-dynamically
>
>Best,
>Yang
>
>casel.chen <ca...@126.com> 于2021年7月9日周五 下午8:29写道:
>
>> flink运行在原生k8s上,现在想要修改Root Logger Level和动态添加 Logger Name -> Logger
>> Level,以及用户可以传入自定义的日志模板,目前有办法做到么?

Re: flink on native k8s要如何动态改变日志配置?

Posted by Yang Wang <da...@gmail.com>.
你直接修改ConfigMap中存储的log4j-console.properties就可以立即生效了,具体参考这里[1]

[1].
https://ci.apache.org/projects/flink/flink-docs-master/docs/deployment/resource-providers/native_kubernetes/#changing-the-log-level-dynamically

Best,
Yang

casel.chen <ca...@126.com> 于2021年7月9日周五 下午8:29写道:

> flink运行在原生k8s上,现在想要修改Root Logger Level和动态添加 Logger Name -> Logger
> Level,以及用户可以传入自定义的日志模板,目前有办法做到么?