Re: 回复:状态恢复参数顺序 -s

2021-03-04 文章 dushang
Okay ,THX -- Sent from: http://apache-flink.147419.n8.nabble.com/

状态恢复参数顺序 -s

2021-03-04 文章 dushang
../bin/flink run -s path -c class test.jar 这里面的-s 必须在最前面么,我换成 ../bin/flink run -c class test.jar -s path 不生效。 -- Sent from: http://apache-flink.147419.n8.nabble.com/

Re: Reply:回复:flink如何在无数据流的情况下也能实现state定时输出的功能

2021-03-01 文章 dushang
之前搞错了,THX -- Sent from: http://apache-flink.147419.n8.nabble.com/

Re: 回复:flink如何在无数据流的情况下也能实现state定时输出的功能

2021-03-01 文章 dushang
其实并不是这样,将timer绑定在key上,到了时间就会回调函数不依赖下一条 -- Sent from: http://apache-flink.147419.n8.nabble.com/

Re: Reply:回复:flink如何在无数据流的情况下也能实现state定时输出的功能

2021-03-01 文章 dushang
之前理解错了,THX -- Sent from: http://apache-flink.147419.n8.nabble.com/

flink如何在无数据流的情况下也能实现state定时输出的功能

2021-02-28 文章 dushang
我想在每天早上八点中定时将state输出到mysql中,利用timer的话是需要在八点附近有一条数据流过来并且判断一下时间才能输出,如何实现在没有数据流过来的时候仍然定时输出state?谢谢 -- Sent from: http://apache-flink.147419.n8.nabble.com/

Re: flink-connector-jdbc 落入mysql的时候timestamp 有时差问题

2020-10-13 文章 dushang
time_zone SYSTEM system_time_zone SYSTEM 我是通过 flink-sql-connector-mysql-cdc获取mysql的binlog。通过flink-connector-jdbc sink到mysql中。 source 中有调节时区的参数。所以读取到的是正确的。但是sink 中没有调节时区的参数。时间就有了时差。 source: CREATE TABLE student ( id INT, name STRING, create_time TIMESTAMP(0), update_time TIMESTAMP(0