rowtime??????????

2020-12-26 文章 ?g???U?[???? 
Hi ??
 
DataStreamtableeventTimerowtime??rowtime8??

Table api ??????rowtime??????

2020-12-18 文章 ?g???U?[???? 

 
??DataStream??Tablerowtime??udtf??sqltableEnv.sql()Rowtime
 attributes must not be in the input rows of a regular join. As a workaround 
you can cast the time attributes of input tables to TIMESTAMP 
before.to_timestampeventTimesql??eventTime


sql: select
 tmp.metric_id as 
metric_id,
 
tmp.metric_config as metric_config,
 startLat,
 destName,
 bizType,
 orderId,
 completedTime,
 orderStatus,
 startHexList,
 cityId,
 type,
 destLat,
 endHexList,
 destLng,
 createTime,
 passengerId,
 finishedTime,
 vehicleId,
 startLng,
 startName,
 eventTime
from
 
htw_order_dwd_htw_order_geo_Infos,
 lateral table(
  
metricUdtf('aa')
 ) as 
tmp(metric_id, metric_config)


Thanks
Jiazhi

Flink eventTIme????

2020-12-17 文章 ?g???U?[???? 
Hi all  When I use SQL with UDTF, when I call the 
tableEnv.sqlQuery () method, I throw the following error: Rowtime attributes 
must not be in the input rows of a regular join. As a workaround you can cast 
the time attributes of input tables to TIMESTAMP before.I used the 
to_timestamp function in eventTIme and it doesn't work,How to solve the 
problem?


sql: select
 tmp.metric_id as 
metric_id,
 
tmp.metric_config as metric_config,
 startLat,
 destName,
 bizType,
 orderId,
 
completedTime,
 
orderStatus,
 
startHexList,
 cityId,
 type,
 destLat,
 endHexList,
 destLng,
 createTime,
 
passengerId,
 
finishedTime,
 vehicleId,
 startLng,
 startName,
 eventTime
from
 
htw_order_dwd_htw_order_geo_Infos,
 lateral table(
  
metricUdtf('aa')
 ) as 
tmp(metric_id, metric_config)


Thanks
Jiazhi

slot????

2020-11-24 文章 ?g???U?[???? 
Hi ??


 
slot1??slot??


??

????????mysql??????flink????????

2020-11-18 文章 ?g???U?[???? 
  
DataStreammysql??flinkdemo??
??
jiazhi

??????????reduce????????

2020-09-12 文章 ?g???U?[???? 
??


   
??windowreducereduce??2??reduce







Thanks

??????ProcessAllWindowFunction??????????????????ValueState????

2020-07-18 文章 ?g???U?[???? 
??

ProcessAllWindowFunction??ValueStateKeydProcessFounctiononTimerProcessAllWindowFunction??


??

State 0????????????

2020-07-13 文章 ?g???U?[???? 
   
ProcessAllWindowFunction0??state??


Thanks

?????? ?????? DataStream????uv????

2020-07-08 文章 ?g???U?[???? 
??




----
??:"1193216154"<1193216...@qq.com;
:2020??7??9??(??) 10:25
??:"user-zh"

?????? DataStream????uv????

2020-07-08 文章 ?g???U?[???? 
stateDescriptornull??


----
??:"Yun Gao"

DataStream????uv????

2020-07-07 文章 ?g???U?[???? 



  
DataStream??apiUV??2
  
1Tumbling??1Time.days(1)??uv
 
trigger
  
2stateTTL


DataStream

Flink DataStream ????UV????

2020-07-07 文章 ?g???U?[???? 



  
DataStream??apiUV??2
1Tumbling??1Time.days(1)??uv
trigger
2stateTTL

 
??
Jiazhi

DataStream??state????

2020-07-06 文章 ?g???U?[???? 
Deal all:


??,statettl?? 
 StateTtlConfig ttlConfig = StateTtlConfig
   
   .newBuilder(Time.days(1))
   
   .setUpdateType(StateTtlConfig.UpdateType.OnCreateAndWrite)
   
   
.setStateVisibility(StateTtlConfig.StateVisibility.NeverReturnExpired)
   
   .build();



??12020-07-07 
08:30:00job2020-07-07 00:00:00~2020-07-07 
23:59:59??job??2020-07-07 08:30:00~2020-07-08 08:30:00???


Thanks
Jiazhi