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

Mon, 01 Feb 2021 01:56:56 -0800 

????, ?????????????? 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??????. ??????????, 
????????????????????????, ??????????????????????????,????????????????????, 
?????????????????

回复