[jira] [Updated] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins

[ https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Shoshin updated FLINK-5256: - Assignee: (was: Alexander Shoshin) > Extend DataSetSingleRowJoin to support Left and

[jira] [Commented] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins

[ https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15754325#comment-15754325 ] Alexander Shoshin commented on FLINK-5256: -- Sorry, I won't be able to work on this issue during

[jira] [Commented] (FLINK-5255) Improve single row check in DataSetSingleRowJoinRule

[ https://issues.apache.org/jira/browse/FLINK-5255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15747924#comment-15747924 ] Alexander Shoshin commented on FLINK-5255: -- Looks cool! I'll add an empty input support and make

[jira] [Commented] (FLINK-5255) Improve single row check in DataSetSingleRowJoinRule

[ https://issues.apache.org/jira/browse/FLINK-5255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15741784#comment-15741784 ] Alexander Shoshin commented on FLINK-5255: -- The problem is that {{Calcite}} tries to transform

[jira] [Commented] (FLINK-3133) Introduce collect()/count()/print() methods in DataStream API

[ https://issues.apache.org/jira/browse/FLINK-3133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15735742#comment-15735742 ] Alexander Shoshin commented on FLINK-3133: -- Sorry, I wanted to take this issue but I am not able

[jira] [Comment Edited] (FLINK-5255) Improve single row check in DataSetSingleRowJoinRule

[ https://issues.apache.org/jira/browse/FLINK-5255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15735215#comment-15735215 ] Alexander Shoshin edited comment on FLINK-5255 at 12/9/16 12:41 PM:

[jira] [Commented] (FLINK-5255) Improve single row check in DataSetSingleRowJoinRule

[ https://issues.apache.org/jira/browse/FLINK-5255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15735215#comment-15735215 ] Alexander Shoshin commented on FLINK-5255: -- Thanks, Fabian, I'll check for {{LogicalCalc}} then.

[jira] [Commented] (FLINK-5255) Improve single row check in DataSetSingleRowJoinRule

[ https://issues.apache.org/jira/browse/FLINK-5255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15734933#comment-15734933 ] Alexander Shoshin commented on FLINK-5255: -- I check join inputs in a {{matches(..)}} method of

[jira] [Comment Edited] (FLINK-5255) Improve single row check in DataSetSingleRowJoinRule

[ https://issues.apache.org/jira/browse/FLINK-5255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15734933#comment-15734933 ] Alexander Shoshin edited comment on FLINK-5255 at 12/9/16 10:32 AM: I

[jira] [Commented] (FLINK-5255) Improve single row check in DataSetSingleRowJoinRule

[ https://issues.apache.org/jira/browse/FLINK-5255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15734839#comment-15734839 ] Alexander Shoshin commented on FLINK-5255: -- I found that we can have a {{LogicalProject}}

[jira] [Assigned] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins

[ https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Shoshin reassigned FLINK-5256: Assignee: Alexander Shoshin > Extend DataSetSingleRowJoin to support Left and

[jira] [Commented] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins

[ https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15722033#comment-15722033 ] Alexander Shoshin commented on FLINK-5256: -- Yes, I am. I will take it. [~fhueske], can you give

[jira] [Commented] (FLINK-5255) Improve single row check in DataSetSingleRowJoinRule

[ https://issues.apache.org/jira/browse/FLINK-5255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15721990#comment-15721990 ] Alexander Shoshin commented on FLINK-5255: -- Hi [~fhueske]. Yes, I would. Thanks > Improve single

[jira] [Assigned] (FLINK-5255) Improve single row check in DataSetSingleRowJoinRule

[ https://issues.apache.org/jira/browse/FLINK-5255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Shoshin reassigned FLINK-5255: Assignee: Alexander Shoshin > Improve single row check in DataSetSingleRowJoinRule

[jira] [Updated] (FLINK-3133) Introduce collect()/count()/print() methods in DataStream API

[ https://issues.apache.org/jira/browse/FLINK-3133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Shoshin updated FLINK-3133: - Assignee: (was: Alexander Shoshin) > Introduce collect()/count()/print() methods in

[jira] [Commented] (FLINK-5159) Improve perfomance of inner joins with a single row input

[ https://issues.apache.org/jira/browse/FLINK-5159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15714311#comment-15714311 ] Alexander Shoshin commented on FLINK-5159: -- [~fhueske], thank you a lot for your help with this

[jira] [Created] (FLINK-5159) Improve perfomance of inner joins with a single row input

Alexander Shoshin created FLINK-5159: Summary: Improve perfomance of inner joins with a single row input Key: FLINK-5159 URL: https://issues.apache.org/jira/browse/FLINK-5159 Project: Flink

[jira] [Commented] (FLINK-3133) Introduce collect()/count()/print() methods in DataStream API

[ https://issues.apache.org/jira/browse/FLINK-3133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15695133#comment-15695133 ] Alexander Shoshin commented on FLINK-3133: -- [~mxm], hi. Can you answer my previous question

[jira] [Commented] (FLINK-3133) Introduce collect()/count()/print() methods in DataStream API

[ https://issues.apache.org/jira/browse/FLINK-3133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15676175#comment-15676175 ] Alexander Shoshin commented on FLINK-3133: -- Hi ) Thanks, Maximilian. I think that now I

[jira] [Commented] (FLINK-3133) Introduce collect()/coun()/print() methods in DataStream API

[ https://issues.apache.org/jira/browse/FLINK-3133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15674029#comment-15674029 ] Alexander Shoshin commented on FLINK-3133: -- [~mxm], could you give more details about this issue

[jira] [Assigned] (FLINK-3133) Introduce collect()/coun()/print() methods in DataStream API

[ https://issues.apache.org/jira/browse/FLINK-3133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Shoshin reassigned FLINK-3133: Assignee: Alexander Shoshin (was: Evgeny Kincharov) > Introduce

[jira] [Commented] (FLINK-4541) Support for SQL NOT IN operator

[ https://issues.apache.org/jira/browse/FLINK-4541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15656831#comment-15656831 ] Alexander Shoshin commented on FLINK-4541: -- NOT IN operator does not work with nested queries

[jira] [Assigned] (FLINK-4541) Support for SQL NOT IN operator

[ https://issues.apache.org/jira/browse/FLINK-4541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Shoshin reassigned FLINK-4541: Assignee: Alexander Shoshin > Support for SQL NOT IN operator >

[jira] [Commented] (FLINK-2118) Table API fails on composite filter conditions

[ https://issues.apache.org/jira/browse/FLINK-2118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15595359#comment-15595359 ] Alexander Shoshin commented on FLINK-2118: -- Fabian, thank you for the fast responce! > Table API

[jira] [Commented] (FLINK-2118) Table API fails on composite filter conditions

[ https://issues.apache.org/jira/browse/FLINK-2118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15595011#comment-15595011 ] Alexander Shoshin commented on FLINK-2118: -- I agree with [~RenkaiGe]. {{'name \!== "Pete" &&

[jira] [Assigned] (FLINK-2118) Table API fails on composite filter conditions

[ https://issues.apache.org/jira/browse/FLINK-2118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Shoshin reassigned FLINK-2118: Assignee: Alexander Shoshin > Table API fails on composite filter conditions >

[jira] [Commented] (FLINK-4283) ExecutionGraphRestartTest fails

[ https://issues.apache.org/jira/browse/FLINK-4283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15585134#comment-15585134 ] Alexander Shoshin commented on FLINK-4283: -- It will look like this:

[jira] [Comment Edited] (FLINK-4283) ExecutionGraphRestartTest fails

[ https://issues.apache.org/jira/browse/FLINK-4283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15582125#comment-15582125 ] Alexander Shoshin edited comment on FLINK-4283 at 10/17/16 12:37 PM: -

[jira] [Commented] (FLINK-4283) ExecutionGraphRestartTest fails

[ https://issues.apache.org/jira/browse/FLINK-4283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15582125#comment-15582125 ] Alexander Shoshin commented on FLINK-4283: -- I agree that these tests shouldn't depends on

[jira] [Commented] (FLINK-4283) ExecutionGraphRestartTest fails

[ https://issues.apache.org/jira/browse/FLINK-4283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15581727#comment-15581727 ] Alexander Shoshin commented on FLINK-4283: -- I found out that these tests will fail if you run

[jira] [Commented] (FLINK-4283) ExecutionGraphRestartTest fails

[ https://issues.apache.org/jira/browse/FLINK-4283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568940#comment-15568940 ] Alexander Shoshin commented on FLINK-4283: -- It is still relevant. I have just strated researching