Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

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

Open
zjfplayer opened this issue Oct 27, 2020 · 3 comments
Open

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

zjfplayer opened this issue Oct 27, 2020 · 3 comments

Comments

@zjfplayer
Copy link

zjfplayer commented Oct 27, 2020 •
edited
Loading

flinkStreamSQL 10月中旬 1.8.7_release分支代码问题
image
@zjfplayer
Copy link
Author

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

@zjfplayer
Copy link
Author

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

@zjfplayer
Copy link
Author

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

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
None yet
Projects
None yet
Milestone
No milestone
Development

No branches or pull requests
1 participant
@zjfplayer