????: ????: ??????????

Mon, 01 Feb 2021 02:03:38 -0800 

????Flink????????????????



 
???????? ???????L
?????????? 2021-02-01 17:56
???????? user-zh
?????? ??????????: ??????????
????, ?????????????? Configuration configuration = 
streamTableEnv.getConfig().getConfiguration();
configuration.setString("table.exec.source.idle-timeout","1000 ms"); 
????????????
 
 
 
 
------------------ ???????? ------------------
??????:                                                                         
                                               "user-zh"                        
                                                            
<[email protected]&gt;;
????????:&nbsp;2021??2??1??(??????) ????5:52
??????:&nbsp;"user-zh"<[email protected]&gt;;
 
????:&nbsp;????: ??????????
 
 
 
hi, ????????????idle source??????????????[1]
 
[1] 
https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/event_timestamps_watermarks.html#dealing-with-idle-sources
 
best,
amenhub
 
 
 
&nbsp;
???????? ???????L
?????????? 2021-02-01 17:20
???????? user-zh
?????? ??????????
flink1.12????, kafka??3??????, flink??????????3??????. ??????????, 
????????????????????????, ??????????????????????????,????????????????????, 
?????????????????

回复