Re: flink sql timed-window join throw "mismatched type" AssertionError on rowtime column

am and follow the logic > of TimeBoundedStreamInnerJoin to do the timed-window join. Should I do > this? Is there any concern from performance or stability perspective? > > Best > Yan > > ------ > *From:* Xingcan Cui > *Sent:* Thursday, March 8, 2018 8

Re: flink sql timed-window join throw "mismatched type" AssertionError on rowtime column

..@gmail.com> *Sent:*Wednesday, March 7, 2018 8:10 PM *To:*Yan Zhou [FDS Science] *Cc:*user@flink.apache.org <mailto:user@flink.apache.org> *Subject:*Re: flink sql timed-window join throw "mismatched type" AssertionError on rowtime column Hi Yan, I’d like to look into this. Can yo

Re: flink sql timed-window join throw "mismatched type" AssertionError on rowtime column

ionError doesn't occur. >>> >>> String sql1 = "select distinct id, eventTs, count(*) over (partition by id >>> order by eventTs rows between 100 preceding and current row) as cnt1 from >>> myTable"; >>> >>> Best >>> Ya

Re: flink sql timed-window join throw "mismatched type" AssertionError on rowtime column

From: Xingcan Cui Sent: Thursday, March 8, 2018 8:21:42 AM To: Timo Walther Cc: user; Yan Zhou [FDS Science] Subject: Re: flink sql timed-window join throw "mismatched type" AssertionError on rowtime column Hi Yan & Timo, this is confirmed to be a bug and I’ve created an

Re: flink sql timed-window join throw "mismatched type" AssertionError on rowtime column

ount(*) over (partition by id >> order by eventTs rows between 100 preceding and current row) as cnt1 from >> myTable"; >> >> Best >> Yan >> From: xccui-foxmail <mailto:xingc...@gmail.com> >> Sent: Wednesday, March 7, 2018 8:10 PM >>

Re: flink sql timed-window join throw "mismatched type" AssertionError on rowtime column

uot;;* > > > Best > Yan > -- > *From:* xccui-foxmail > *Sent:* Wednesday, March 7, 2018 8:10 PM > *To:* Yan Zhou [FDS Science] > *Cc:* user@flink.apache.org > *Subject:* Re: flink sql timed-window join throw "mismatched type" > As

Re: flink sql timed-window join throw "mismatched type" AssertionError on rowtime column

ect:* Re: flink sql timed-window join throw "mismatched type" AssertionError on rowtime column Hi Yan, I’d like to look into this. Can you share more about your queries and the full stack trace? Thank, Xingcan On 8 Mar 2018, at 11:28 AM, Yan Zhou [FDS Science] <mailto:yz...@coupang.

Re: flink sql timed-window join throw "mismatched type" AssertionError on rowtime column

tion by id order by eventTs rows between 100 preceding and current row) as cnt1 from myTable"; Best Yan From: xccui-foxmail Sent: Wednesday, March 7, 2018 8:10 PM To: Yan Zhou [FDS Science] Cc: user@flink.apache.org Subject: Re: flink sql timed-window join th

Re: flink sql timed-window join throw "mismatched type" AssertionError on rowtime column

Hi Yan, I’d like to look into this. Can you share more about your queries and the full stack trace? Thank, Xingcan > On 8 Mar 2018, at 11:28 AM, Yan Zhou [FDS Science] > wrote: > > Hi experts, > I am using flink table api to join two tables, which are datastream >

flink sql timed-window join throw "mismatched type" AssertionError on rowtime column

Hi experts, I am using flink table api to join two tables, which are datastream underneath. However, I got an assertion error of "java.lang.AssertionError: mismatched type $1 TIMESTAMP(3)" on rowtime column. Below is more details: There in only one kafka data source, which is then converted to