Re: flink sql 读取mysql

[Caizhi Weng]

Hi,

关于数据修改后还是读到旧数据的问题，可能是因为配置了 cache。我看到超时时间配置的是 'connector.lookup.cache.ttl' =
'10min'，也就是说数据修改后最长要 10 分钟 Flink 才会读到修改后的数据。

admin <17626017...@163.com> 于2020年7月24日周五 下午7:32写道：

>  'connector.properties.zookeeper.connect' = '',  -- zk 地址
>'connector.properties.bootstrap.servers' = '',  -- broker 地址
>
> 'connector.username' = '',
>'connector.password' = ‘',
> 这几行有问题吧
>
> > 2020年7月24日 下午4:20，liunaihua521  写道：
> >
> >  'connector.properties.zookeeper.connect' = '',  -- zk 地址
> >'connector.properties.bootstrap.servers' = '',  -- broker 地址
>
>

Re: flink sql 读取mysql

[admin]

 'connector.properties.zookeeper.connect' = '',  -- zk 地址
   'connector.properties.bootstrap.servers' = '',  -- broker 地址

'connector.username' = '',
   'connector.password' = ‘',
这几行有问题吧

> 2020年7月24日 下午4:20，liunaihua521  写道：
> 
>  'connector.properties.zookeeper.connect' = '',  -- zk 地址
>'connector.properties.bootstrap.servers' = '',  -- broker 地址

Re: flink sql 读取mysql

[Leonard Xu]

Hello

这个报错一般是sql格式错误，比如中英文逗号等，你可以检查下你的SQL语句

祝好
Leonard Xu
> 在 2020年7月24日，16:20，liunaihua521  写道：
> 
> org.apache.flink.table.api.SqlParserExcption:Sql parse failed.Encountered 
> "timestamp,"at line
> Was expecting one of:
> "CURSOR"...

Re: flink sql 读取mysql

[Leonard Xu]

另外社区中文邮件交流直接发邮件到user-zh@flink.apache.org 
就可以了，不用发user-zh-...@flink.apache.org 
 这个地址。


> 在 2020年7月24日，14:25，Leonard Xu  写道：
> 
> Hello
> 图挂了，可以贴下DDL吗？另外你没有使用维表join语法 FOR SYSTEM_TIME AS OF[1] 
> 
> 祝好
> Leonard Xu
> [1] 
> https://ci.apache.org/projects/flink/flink-docs-release-1.11/zh/dev/table/sql/queries.html#joins
>  
> 
>  
> 
>> 在 2020年7月24日，14:14，liunaihua521 > > 写道：
>> 
>> hi!
>> 版本:flink  1.10
>> mysql 5.7.24
>> 
>> 需求场景是:
>> 使用flink SQL,读取kafka数据,和mysql的维表数据,之后进行join操作,如何配置mysql 
>> connector,才能使维表数据修改后,flink能读取到更新后的数据进行join操作?
>> 
>> 现在本地测试时,维表的DDL是:
>> 
>> 但是去mysql修改了数据后,join操作还是旧数据.
>> 
>> 望大神们指点方向,提前谢谢了.
>> 
>> 
>> 
> 

Re: flink sql 读取mysql

[Leonard Xu]

Hello
图挂了，可以贴下DDL吗？另外你没有使用维表join语法 FOR SYSTEM_TIME AS OF[1] 

祝好
Leonard Xu
[1] 
https://ci.apache.org/projects/flink/flink-docs-release-1.11/zh/dev/table/sql/queries.html#joins
 

 

> 在 2020年7月24日，14:14，liunaihua521  写道：
> 
> hi!
> 版本:flink  1.10
> mysql 5.7.24
> 
> 需求场景是:
> 使用flink SQL,读取kafka数据,和mysql的维表数据,之后进行join操作,如何配置mysql 
> connector,才能使维表数据修改后,flink能读取到更新后的数据进行join操作?
> 
> 现在本地测试时,维表的DDL是:
> 
> 但是去mysql修改了数据后,join操作还是旧数据.
> 
> 望大神们指点方向,提前谢谢了.
> 
> 
>