flink per job taskmanager 日志查看问题

Hi: 请教一个问题，我flink(1.12.0) 以per-job的方式运行在yarn上，在yarn的web UI(jobhistory)上只能看到jobmanager.log以及jobmanager.err，看不到taskmanager有关的日志。我用yarn logs -applicationId appId命令可以查看到taskmanager.log的日志。 这样的问题是yarn的问题还是flink 日志设置的问题？有哪位同学处理过？怎么处理的？ 感谢。 新春快乐 automths

??????flink per job taskmanager ????????????

??1 Flink Web UI Job Manager ?? Task Manager ?? per-job ?? Flink Web UI Found Web Interface xxx(ip):xx(port) of application 'application__XXX'. ?? Flink Web UI ??xxx(ip):xx(port)??

??????flink per job taskmanager ????????????

??1 Flink Web UI Job Manager ?? Task Manager ?? per-job ?? Flink Web UI Found Web Interface xxx(ip):xx(port) of application 'application__XXX'. ?? Flink Web UI ??xxx(ip):xx(port)??

??????flink per job taskmanager ????????????

Hi: ?? automths ??2021??02??9?? 22:33??471419897<471419...@qq.com> ?? ??1 Flink Web UI Job Manager ?? Task Manager ?? per-job ?? Flink Web UI Found Web Inte

答复: procesElement中每天数据都put 进入map，但下一条数据来时map都是空的咨询

可能是你没有在open方法里从上下文获取mapstate e.g.: map = getRuntimeContext().getMapState(new MapStateDescriptor(mapname, xx.class, xx.class))吗 -邮件原件- 发件人: 谌祖安 [mailto:shenz...@pcitech.com] 发送时间: 2021年2月7日 星期日 16:25 收件人: user-zh 主题: procesElement中每天数据都put 进入map，但下一条数据来时map都是空的咨询 您好！ 重载procesElement方法

Re: Flink SQL temporal table join with Hive 报错

Hi, macia > 在 2021年2月9日，10:40，macia kk 写道： > > SELECT *FROM >( >SELECT tt.* >FROM >input_tabe_01 tt >FULL OUTER JOIN input_tabe_02 mt >ON (mt.transaction_sn = tt.reference_id) >and tt.create_time >= mt.create_time + INTERVAL '