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.

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

Filter does not work when joining with table #1568

Closed
mohanvive opened this issue Nov 15, 2019 · 1 comment
Closed

Filter does not work when joining with table #1568

mohanvive opened this issue Nov 15, 2019 · 1 comment

Comments

@mohanvive
Copy link
Contributor

Description:
Filter is not obeyed when joining a stream with table. Below query, does not work as expected

from Stream1[x>123]
  join Table1
  on Stream1.id == Table1.id
select Stream1.x
insert into OutputStream; 
@suhothayan
Copy link
Contributor

This is a bug introduced by the resent optimization done on joins. As a workaround, please add a length(1) window after the filter to enforce the filter condition to be matched.

from Stream1[x>123]#window.length(1)
  join Table1
  on Stream1.id == Table1.id
select Stream1.x
insert into OutputStream; 

I'll work on fixing this.

@suhothayan suhothayan self-assigned this Nov 16, 2019
suhothayan added a commit to suhothayan/siddhi that referenced this issue Nov 18, 2019
mohanvive added a commit that referenced this issue Nov 18, 2019
Filter does not work when joining with table #1568
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

No branches or pull requests

2 participants