Even if the time attribute field is retained, will the related watermark be retained? If not, and there is no sql syntax to declare watermark again, it is equivalent to not being able to do multiple joins in one job.
Benchao Li <libenc...@gmail.com> 于2020年5月5日周二 下午9:23写道： > You cannot select more than one time attribute, the planner will give you > an Exception if you did that. > > > lec ssmi <shicheng31...@gmail.com> 于2020年5月5日周二 下午8:34写道： > >> As you said, if I select all the time attribute fields from >> both , which will be the final one？ >> >> Benchao Li <libenc...@gmail.com> 于 2020年5月5日周二 17:26写道： >> >>> Hi lec, >>> >>> You don't need to specify time attribute again like `TUMBLE_ROWTIME`, >>> you just select the time attribute field >>> from one of the input, then it will be time attribute automatically. >>> >>> lec ssmi <shicheng31...@gmail.com> 于2020年5月5日周二 下午4:42写道： >>> >>>> But I have not found there is any syntax to specify time >>>> attribute field and watermark again with pure sql. >>>> >>>> Fabian Hueske <fhue...@gmail.com> 于 2020年5月5日周二 15:47写道： >>>> >>>>> Sure, you can write a SQL query with multiple interval joins that >>>>> preserve event-time attributes and watermarks. >>>>> There's no need to feed data back to Kafka just to inject it again to >>>>> assign new watermarks. >>>>> >>>>> Am Di., 5. Mai 2020 um 01:45 Uhr schrieb lec ssmi < >>>>> shicheng31...@gmail.com>: >>>>> >>>>>> I mean using pure sql statement to make it . Can it be possible? >>>>>> >>>>>> Fabian Hueske <fhue...@gmail.com> 于2020年5月4日周一 下午4:04写道： >>>>>> >>>>>>> Hi, >>>>>>> >>>>>>> If the interval join emits the time attributes of both its inputs, >>>>>>> you can use either of them as a time attribute in a following operator >>>>>>> because the join ensures that the watermark will be aligned with both of >>>>>>> them. >>>>>>> >>>>>>> Best, Fabian >>>>>>> >>>>>>> Am Mo., 4. Mai 2020 um 00:48 Uhr schrieb lec ssmi < >>>>>>> shicheng31...@gmail.com>: >>>>>>> >>>>>>>> Thanks for your replay. >>>>>>>> But as I known, if the time attribute will be retained and the >>>>>>>> time attribute field of both streams is selected in the result after >>>>>>>> joining, who is the final time attribute variable? >>>>>>>> >>>>>>>> Benchao Li <libenc...@gmail.com> 于2020年4月30日周四 下午8:25写道： >>>>>>>> >>>>>>>>> Hi lec, >>>>>>>>> >>>>>>>>> AFAIK, time attribute will be preserved after time interval join. >>>>>>>>> Could you share your DDL and SQL queries with us? >>>>>>>>> >>>>>>>>> lec ssmi <shicheng31...@gmail.com> 于2020年4月30日周四 下午5:48写道： >>>>>>>>> >>>>>>>>>> Hi: >>>>>>>>>> I need to join multiple stream tables using time interval >>>>>>>>>> join. The problem is that the time attribute will disappear after >>>>>>>>>> the jon >>>>>>>>>> , and pure sql cannot declare the time attribute field again . So, >>>>>>>>>> to >>>>>>>>>> make is success, I need to insert the last result of join to kafka >>>>>>>>>> ,and >>>>>>>>>> consume it and join it with another stream table in another flink >>>>>>>>>> job >>>>>>>>>> . This seems troublesome. >>>>>>>>>> Any good idea? >>>>>>>>>> >>>>>>>>>> >>>>>>>>>> >>>>>>>>> >>>>>>>>> -- >>>>>>>>> >>>>>>>>> Benchao Li >>>>>>>>> School of Electronics Engineering and Computer Science, Peking >>>>>>>>> University >>>>>>>>> Tel:+86-15650713730 >>>>>>>>> Email: libenc...@gmail.com; libenc...@pku.edu.cn >>>>>>>>> >>>>>>>>> >>> >>> -- >>> >>> Benchao Li >>> School of Electronics Engineering and Computer Science, Peking University >>> Tel:+86-15650713730 >>> Email: libenc...@gmail.com; libenc...@pku.edu.cn >>> >>> > > -- > > Benchao Li > School of Electronics Engineering and Computer Science, Peking University > Tel:+86-15650713730 > Email: libenc...@gmail.com; libenc...@pku.edu.cn > >
