date:20201113

flink sql ddl连接kafka,flink sql使用事件时间无法正常触发时间窗口

2020-11-13 文章李世钰

flink版本 flink1.11 flink sql连接kafka create table kafka_table ( log_id string, event_time bigint, process_time as PROCTIME(), ts as TO_TIMESTAMP(FROM_UNIXTIME(event_time)), watermark for ts as ts - interval '1' second ) with ( 'connector' = 'kafka', 'topic' = 'kafka_table', 'properties.bootstra

Re: 邮件退订

2020-11-13 文章 Shawn Huang

Hi, 退订需要发邮件到 user-zh-unsubscr...@flink.apache.org 可以参考 https://flink.apache.org/zh/community.html#section-1 Best, Shawn Huang wangleigis 于2020年11月14日周六上午11:55写道： > > > > > > > 退订 > > > > > > > > > > > -- > > 祝：工作顺利，完事如意！

邮件退订

2020-11-13 文章 wangleigis

退订 -- 祝：工作顺利，完事如意！

回复: Re:回复: flink-1.11.2 执行checkpoint失败

2020-11-13 文章史正超

谢谢回复，我看了下我的任务，是背压导致的checkpoint超时，超时是没有异常日志打印的，每超时一次就打印 org.apache.flink.util.FlinkRuntimeException: Exceeded checkpoint tolerable failure threshold. 这里的failure counter是 checkpoint的count。任务是没有挂的，只是一直背压了。发件人: hailongwang <18868816...@163.com> 发送时间: 2020年11月13日 6

Flink cdc 多表关联处理延迟很大

2020-11-13 文章丁浩浩

我用flink cdc 对mysql的表进行关联查询，发现flink只能两张表关联之后再跟下一张表关联，导致最后落库的延迟非常大。有没有比较好的优化方案能缓解这样的问题？

Re:确认订阅user-zh@flink.apache.org

2020-11-13 文章 hailongwang

Hi, 订阅中文用户邮件需发送至 user-zh-subscr...@flink.apache.org , 更多详细情况可以参考[1] [1] https://flink.apache.org/community.html#mailing-lists Best, hailong At 2020-11-13 17:12:40, "黑色" wrote:

????????user-zh@flink.apache.org

2020-11-13 文章 ????

Re: pyflink 1.11 运行pyflink作业时报错

2020-11-13 文章 Dian Fu

看起来是的，找不到JAVA_HOME，显式export一下JAVA_HOME试试？ > 在 2020年11月13日，下午5:06，whh_960101 写道： > > Hi，各位大佬，pyflink 1.11 运行pyflink作业时报错pyflink/pyfink_gateway_server.py 193行 > lauch_gateway_server_process()217行 return Popen（）FileNotFoundError： [Error 2] > No such file or directory: 'java' : 'java'感觉像找不到ja

pyflink 1.11 运行pyflink作业时报错

2020-11-13 文章 whh_960101

Hi，各位大佬，pyflink 1.11 运行pyflink作业时报错pyflink/pyfink_gateway_server.py 193行 lauch_gateway_server_process()217行 return Popen（）FileNotFoundError： [Error 2] No such file or directory: 'java' : 'java'感觉像找不到java路径还是什么意思，java：java没看懂，该怎么解决

Re: flink-1.11 使用 application 模式时 jobid 问题

2020-11-13 文章 zhisheng

看完还是没有解决😂方案啊 JasonLee <17610775...@163.com> 于2020年11月13日周五下午4:10写道： > hi > 可以参考一下这篇文章: https://mp.weixin.qq.com/s/S_Spm88eDtbza1QoLKiWlg > > > > - > Best Wishes > JasonLee > -- > Sent from: http://apache-flink.147419.n8.nabble.com/ >