Hi,
In Flink 13, while using filter/where condition in table api I am getting
wrong results. Upon debugging I found that it is adding padding to the IN
clause elements according to the first element in the IN clause.
Here's the sample code
tEnv.toAppendStream(input.where($("ename").in("O2CartPageLoaded","OrderPlaced","O2MenuViewed","opened_app"))
.select($("ename")), Utils.getTypeInfo("ename:string")).print();
Screenshot of hashset
[image: Screenshot 2021-11-29 at 16.24.59.png]
If I change the IN clasue element order, then the padding also changes
tEnv.toAppendStream(input.where($("ename").in("OrderPlaced","O2CartPageLoaded","O2MenuViewed","opened_app"))
.select($("ename")), Utils.getTypeInfo("ename:string")).print();
Screenshot of hashset
[image: Screenshot 2021-11-29 at 16.23.20.png]
--
Ayush Chauhan
Data Platform
--
This email is intended only for the person or the entity to
whom it is addressed. If you are not the intended recipient, please delete
this email and contact the sender.
