flinkStreamSQL icon indicating copy to clipboard operation
flinkStreamSQL copied to clipboard

Published 20 hours ago • verified publisher icon DTStack

join后的where中流表和维表同名字段值取反

Open zjfplayer opened this issue 5 years ago • 3 comments

flinkStreamSQL 10月中旬 1.8.7_release分支代码问题 image

zjfplayer avatar Oct 27 '20 09:10 zjfplayer

com.dtstack.flink.sql.side.rdb.async.RdbAsyncReqRow#handleQuery 里面rowlist有值，且消息中的同名字段的值是对的

zjfplayer avatar Oct 27 '20 09:10 zjfplayer

将C表和A表同名字段select中顺序调整下，就能输出了 image

zjfplayer avatar Oct 28 '20 03:10 zjfplayer

找到原因了，是因为 image 这里是按照join顺序拼接表字段，然后有重复再重命名 但是JoinNodeDealer#replaceSelectAndWhereField中 image 字段重名判断修改为重命名是按照select顺序， 所以如果select 先后表的重名字段，在前表的重名字段，就会queue里面跟createView的不一致，导致字段取错，这个要看你们怎么修复，希望与袋鼠云修复设计一致，不然后续sql层面的bug可能因为设计不一致没法merge了

zjfplayer avatar Oct 28 '20 08:10 zjfplayer