Okay ,THX
--
Sent from: http://apache-flink.147419.n8.nabble.com/
../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/
之前搞错了,THX
--
Sent from: http://apache-flink.147419.n8.nabble.com/
其实并不是这样,将timer绑定在key上,到了时间就会回调函数不依赖下一条
--
Sent from: http://apache-flink.147419.n8.nabble.com/
之前理解错了,THX
--
Sent from: http://apache-flink.147419.n8.nabble.com/
我想在每天早上八点中定时将state输出到mysql中,利用timer的话是需要在八点附近有一条数据流过来并且判断一下时间才能输出,如何实现在没有数据流过来的时候仍然定时输出state?谢谢
--
Sent from: http://apache-flink.147419.n8.nabble.com/
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