[jira] [Commented] (FLINK-9528) Incorrect results: Filter does not treat Upsert messages correctly.

[ https://issues.apache.org/jira/browse/FLINK-9528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109381#comment-17109381 ] Hequn Cheng commented on FLINK-9528: [~jark] (y) > Incorrect results: Filter does not treat Upsert

[jira] [Commented] (FLINK-9528) Incorrect results: Filter does not treat Upsert messages correctly.

[ https://issues.apache.org/jira/browse/FLINK-9528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17078413#comment-17078413 ] Timo Walther commented on FLINK-9528: - I changed the component to Blink planner. > Incorrect

[jira] [Commented] (FLINK-9528) Incorrect results: Filter does not treat Upsert messages correctly.

[ https://issues.apache.org/jira/browse/FLINK-9528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17078290#comment-17078290 ] Jark Wu commented on FLINK-9528: Hi [~twalthr], this is not resolved in Blink planner yet. But we have a

[jira] [Commented] (FLINK-9528) Incorrect results: Filter does not treat Upsert messages correctly.

[ https://issues.apache.org/jira/browse/FLINK-9528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17078248#comment-17078248 ] Fabian Hueske commented on FLINK-9528: -- Thanks for the update [~hequn8128]! I'll reopen the ticket

[jira] [Commented] (FLINK-9528) Incorrect results: Filter does not treat Upsert messages correctly.

[ https://issues.apache.org/jira/browse/FLINK-9528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17078244#comment-17078244 ] Hequn Cheng commented on FLINK-9528: Hi everyone, I have freed this ticket as I have switched my work

[jira] [Commented] (FLINK-9528) Incorrect results: Filter does not treat Upsert messages correctly.

[ https://issues.apache.org/jira/browse/FLINK-9528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17078225#comment-17078225 ] Fabian Hueske commented on FLINK-9528: -- I agree with [~twalthr]. I don't think we should close bug

[jira] [Commented] (FLINK-9528) Incorrect results: Filter does not treat Upsert messages correctly.

[ https://issues.apache.org/jira/browse/FLINK-9528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17078220#comment-17078220 ] Timo Walther commented on FLINK-9528: - [~jark] is this issue solved in the Blink planner? It actually

[jira] [Commented] (FLINK-9528) Incorrect results: Filter does not treat Upsert messages correctly.

[ https://issues.apache.org/jira/browse/FLINK-9528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16512534#comment-16512534 ] Fabian Hueske commented on FLINK-9528: -- I don't think we need state in all Filters working under

[jira] [Commented] (FLINK-9528) Incorrect results: Filter does not treat Upsert messages correctly.

[ https://issues.apache.org/jira/browse/FLINK-9528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16510544#comment-16510544 ] Hequn Cheng commented on FLINK-9528: You are right, we should not add state to all filters. Add state

[jira] [Commented] (FLINK-9528) Incorrect results: Filter does not treat Upsert messages correctly.

[ https://issues.apache.org/jira/browse/FLINK-9528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16509320#comment-16509320 ] Fabian Hueske commented on FLINK-9528: -- I think we can provide efficient implementations for all

[jira] [Commented] (FLINK-9528) Incorrect results: Filter does not treat Upsert messages correctly.

[ https://issues.apache.org/jira/browse/FLINK-9528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16508175#comment-16508175 ] Hequn Cheng commented on FLINK-9528: Hi, [~fhueske] If we agree to add a state we can simply add the

[jira] [Commented] (FLINK-9528) Incorrect results: Filter does not treat Upsert messages correctly.

[ https://issues.apache.org/jira/browse/FLINK-9528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16504489#comment-16504489 ] Fabian Hueske commented on FLINK-9528: -- True, highly-selective filters would definitely be an issue.

[jira] [Commented] (FLINK-9528) Incorrect results: Filter does not treat Upsert messages correctly.

[ https://issues.apache.org/jira/browse/FLINK-9528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16504471#comment-16504471 ] Hequn Cheng commented on FLINK-9528: Hi, [~fhueske]. Considering the anti-spamming scenario, users

[jira] [Commented] (FLINK-9528) Incorrect results: Filter does not treat Upsert messages correctly.

[ https://issues.apache.org/jira/browse/FLINK-9528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16503155#comment-16503155 ] Fabian Hueske commented on FLINK-9528: -- Hi [~hequn8128], can you explain in more detail what you

[jira] [Commented] (FLINK-9528) Incorrect results: Filter does not treat Upsert messages correctly.

[ https://issues.apache.org/jira/browse/FLINK-9528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16502103#comment-16502103 ] Hequn Cheng commented on FLINK-9528: You are right. The duplicate delete messages in upsert mode

[jira] [Commented] (FLINK-9528) Incorrect results: Filter does not treat Upsert messages correctly.

[ https://issues.apache.org/jira/browse/FLINK-9528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16501716#comment-16501716 ] Fabian Hueske commented on FLINK-9528: -- It is correct that a Filter might emit duplicate delete

[jira] [Commented] (FLINK-9528) Incorrect results: Filter does not treat Upsert messages correctly.

[ https://issues.apache.org/jira/browse/FLINK-9528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16501601#comment-16501601 ] Hequn Cheng commented on FLINK-9528: Hi [~fhueske], Thanks for reporting this. What about setting