??????????FlinkSQL????????????
hi??sql?? ---- ??: "user-zh"
?????? [????????] Stream SQL window join ????
hi ??window??trigger??evitor?? ---- ??: "user-zh" https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/stream/operators/joining.html Best, Danny Chan
?????? KeyedCoProcessFunction??????????????????????????????????
hi, https://blog.csdn.net/yuchuanchen/article/details/105677408 ---- ??: "user-zh"
flink slot????????????????
hi??all flink slot??slottasknetworkbufferpool?? 1/slost(??)??managed memory??
??????flink elasticsearch sink ????????????
hi. source?? ---- ??: "user-zh"
?????? Re: Table Api????sql????????sink??????
hi: sink ??tabledatastreamsink??dataStream.addSink(sink)(??), ?? ---- ??: "user-zh" https://www.mail-archive.com/dev@flink.apache.org/msg40251.html wldd https://ci.apache.org/projects/flink/flink-docs-stable/ops/config.html wldd
回复：flink1.11日志上报
应该没有api,官网推荐的也是log appder这种方式。用这种方式采集的日志是比较全的 ---原始邮件--- 发件人: "Dream-底限"
??????flink1.11????????
?? logback??appder( flink log4j??conf)??appder(flinktaskmanager??applicationIdjar??appder)??MDC.put(),appIdappder?? ---- ??: "user-zh"
??????flink job ?????????? watermark ????????????
??idea??local?? ---- ??: "user-zh"
?????? flink on yarn????????
logback??appder??appder(flinktaskmanager??applicationIdjar??appder)??MDC.put(),appIdappder?? ---- ??: "user-zh" https://logging.apache.org/log4j/2.x/manual/appenders.html Best, Yangze Guo On Tue, Jul 14, 2020 at 4:46 PM nicygan https://ci.apache.org/projects/flink/flink-docs-master/zh/dev/task_failure_recovery.html gt; gt;gt; gt; gt; gt; gt;gt; gt; gt; Best, gt; gt;gt; gt; gt; Yangze Guo gt; gt;gt; gt; gt; gt; gt;gt; gt; gt; gt; gt;gt; gt; gt; On Mon, Jul 13, 2020 at 2:40 PM <13162790...@163.comgt; wrote: gt; gt;gt; gt; gt; gt; gt; gt;gt; gt; gt; gt; nbsp; gt; gt;gt; gt; gt; gt; 1 gt; gt;gt; gt; gt; gt; 2 per-job gt; gt;gt; gt; gt; gt; 3 cdh flink.1.10 gt; gt;gt; gt; gt; gt; gt; gt;gt; gt; gt; gt; gt; gt;gt; gt; gt; gt; gt; gt;gt; gt; gt; gt; gt; gt;gt; gt; gt; gt; gt; gt;gt; gt; gt; gt; gt; gt;gt; gt; gt; gt; gt; gt;gt; gt; gt; gt; gt; gt;gt; gt; gt; gt; gt; gt;gt; gt; gt; gt; gt; gt;gt; gt; gt; gt; gt; gt;gt; gt; gt; gt; gt; gt;gt; gt; gt; gt; gt; gt;gt; gt; gt; gt; gt; gt;gt; gt; gt; gt; ?? 2020-07-13 11:18:46??"Yangze Guo" https://ci.apache.org/projects/flink/flink-docs-master/zh/ops/deployment/yarn_setup.html#log-files gt; gt;gt; gt; gt; gt; gt;[2] gt; gt;gt; gt; gt; gt; gt;gt; https://ci.apache.org/projects/flink/flink-docs-master/zh/ops/deployment/#per-job-mode gt; gt;gt; gt; gt; gt; gt;[3] gt; gt;gt; gt; gt; gt; gt;gt; https://ci.apache.org/projects/flink/flink-docs-master/zh/ops/deployment/yarn_setup.html#run-a-single-flink-job-on-yarn gt; gt;gt; gt; gt; gt; gt; gt; gt;gt; gt; gt; gt; gt; gt; gt;gt; gt; gt; gt; gt;Best, gt; gt;gt; gt; gt; gt; gt;Yangze Guo gt; gt;gt; gt; gt; gt; gt; gt; gt;gt; gt; gt; gt; gt;On Mon, Jul 13, 2020 at 10:49 AM <13162790...@163.comgt; wrote: gt; gt;gt; gt; gt; gt; gt;gt; gt; gt;gt; gt; gt; gt; gt;gt; gt; gt;gt; gt; gt; gt; gt;gt; 1 flink on yarn?? taskmanager ?? gt; gt;gt; gt; gt; ??es ??taskmanager gt; gt;gt; gt; gt; gt; gt;gt; 2 flink on yarn ??taskmanager ??jobmanager gt; gt;gt; gt; gt; ?? ??nbsp;nbsp; task taskmanager??jobmanager?? gt; gt;gt; gt; gt; gt; gt;gt; gt; gt;gt; gt; gt; gt; gt;gt;
?????? Re: Re: flink on yarn????????
---- ??: "user-zh" https://logging.apache.org/log4j/2.x/manual/appenders.html Best, Yangze Guo On Tue, Jul 14, 2020 at 4:46 PM nicygan https://ci.apache.org/projects/flink/flink-docs-master/zh/dev/task_failure_recovery.html Best, Yangze Guo On Mon, Jul 13, 2020 at 2:40 PM <13162790...@163.com wrote: 1 2 per-job 3 cdh flink.1.10 ?? 2020-07-13 11:18:46??"Yangze Guo" https://ci.apache.org/projects/flink/flink-docs-master/zh/ops/deployment/yarn_setup.html#log-files [2] https://ci.apache.org/projects/flink/flink-docs-master/zh/ops/deployment/#per-job-mode [3] https://ci.apache.org/projects/flink/flink-docs-master/zh/ops/deployment/yarn_setup.html#run-a-single-flink-job-on-yarn Best, Yangze Guo On Mon, Jul 13, 2020 at 10:49 AM <13162790...@163.com wrote: 1 flink on yarn?? taskmanager ?? ??es ??taskmanager 2 flink on yarn ??taskmanager ??jobmanager ?? ?? task taskmanager??jobmanager??
