-nbsp;nbsp;--
??:nbsp;"Leonard Xu"mailto:xbjt...@gmail.comgt;;
:nbsp;2020??6??10??(??) 1:16
??:nbsp;"user-zh"mailto:user-zh@flink.apache.orggt;;
:nbsp;Re: flinksql between
Hi,
source()??nbsp; ??mysq
Stream(StreamTableEnvironmentImpl.scala:94)
> at
> com.jwell56.networksyslog.jobs.jobsource.MysqlLogToES$.main(MysqlLogToES.scala:77)
> at
> com.jwell56.networksyslog.jobs.jobsource.MysqlLogToES.main(MysqlLogToES.scala)
>
>
>
>
>
> --原始邮件--
??valuemysqlinst
??
?? 2020-06-10 15:25
user-zh
?? ?? flinksql between
flink1.10.0
flink1.10.0 ??
tnv.registerDataStream("sqlStream",mysqlinst,'start_ip,'end_ip,'area_id,'unit_id,'device_id)
导 已经可以实现，可以再问一下 如果我join的是一个mysql维表 我是自定义的source定时更新mysql表这样跟流表关联是可以的吗？
>
>
>
>
> --原始邮件--
> 发件人:"wangweigu...@stevegame.cn" 发送时间:2020年6月9日(星期二) 晚上6:35
> 收件人:"user-zh"
> 主题:回复: 回复： 关于flinksql between问题
>
&g
uot;wangweigu...@stevegame.cn" 发送时间:2020年6月9日(星期二) 晚上6:35
> 收件人:"user-zh"
> 主题:回复: 回复： 关于flinksql between问题
>
>
>
>
> 我在1.10中用 useBlinkPlanner是可以的，用useOldPlanner是不可以的！
>
> 会报你下面的错误：
> Exception in thread "main"
> org.apache
hi, ?? ??joinmysql
sourcemysql
----
??:"wangweigu...@stevegame.cn"
user-zh
?? ?????? flinksql between
hi
1 flink1.9.0
2 oldplanner
hi
1 flink1.9.0
2 oldplanner
方便补充一下以下信息么？
1. 你使用的Flink的版本？
2. 使用的planner，是blink planner还是old planner？
3. 用的是streaming mode还是batch mode？
4. 具体的报错信息是什么？
小屁孩 <932460...@qq.com> 于2020年6月9日周二 下午4:26写道：
> hi，我在flinksql中使用 select * from a join b on a.ip b.endip 报了一个错误 不支持此功能 类似这种有没有类似between的函数可以使用
hi??flinksql?? select * from a join b on a.ip
11 matches
Mail list logo
