[GitHub] flink pull request #2811: [FLINK-4541] Support for SQL NOT IN operator

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2811#discussion_r89461812 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataSet/DataSetSingleRowCrossRule.scala --- @@ -0,0 +1,83 @@

[GitHub] flink pull request #2811: [FLINK-4541] Support for SQL NOT IN operator

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2811#discussion_r89486698 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataSet/DataSetSingleRowCrossRule.scala --- @@ -0,0 +1,83 @@

[GitHub] flink pull request #2811: [FLINK-4541] Support for SQL NOT IN operator

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2811#discussion_r89480684 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/DataSetSingleRowCross.scala --- @@ -0,0 +1,180 @@ +/*

[GitHub] flink pull request #2811: [FLINK-4541] Support for SQL NOT IN operator

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2811#discussion_r89480767 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/DataSetSingleRowCross.scala --- @@ -0,0 +1,180 @@ +/*

[GitHub] flink pull request #2811: [FLINK-4541] Support for SQL NOT IN operator

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2811#discussion_r89465992 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/DataSetSingleRowCross.scala --- @@ -0,0 +1,180 @@ +/*

[GitHub] flink pull request #2811: [FLINK-4541] Support for SQL NOT IN operator

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2811#discussion_r89483310 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/DataSetSingleRowCross.scala --- @@ -0,0 +1,180 @@ +/*

[GitHub] flink pull request #2811: [FLINK-4541] Support for SQL NOT IN operator

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2811#discussion_r89483428 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/RichMapRunner.scala --- @@ -0,0 +1,52 @@ +/* + * Licensed to

[GitHub] flink pull request #2811: [FLINK-4541] Support for SQL NOT IN operator

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2811#discussion_r89462392 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/RichMapRunner.scala --- @@ -0,0 +1,52 @@ +/* + * Licensed to

[GitHub] flink pull request #2811: [FLINK-4541] Support for SQL NOT IN operator

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2811#discussion_r89480259 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/DataSetSingleRowCross.scala --- @@ -0,0 +1,180 @@ +/*

[GitHub] flink pull request #2811: [FLINK-4541] Support for SQL NOT IN operator

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2811#discussion_r89482516 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/DataSetSingleRowCross.scala --- @@ -0,0 +1,180 @@ +/*

[GitHub] flink pull request #2811: [FLINK-4541] Support for SQL NOT IN operator

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2811#discussion_r89483891 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/RichMapRunner.scala --- @@ -0,0 +1,52 @@ +/* + * Licensed to

[GitHub] flink pull request #2811: [FLINK-4541] Support for SQL NOT IN operator

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2811#discussion_r89466031 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataSet/DataSetSingleRowCrossRule.scala --- @@ -0,0 +1,83 @@

[GitHub] flink pull request #2811: [FLINK-4541] Support for SQL NOT IN operator

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2811#discussion_r89461025 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataSet/DataSetSingleRowCrossRule.scala --- @@ -0,0 +1,83 @@

[GitHub] flink pull request #2811: [FLINK-4541] Support for SQL NOT IN operator

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2811#discussion_r89465952 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/DataSetSingleRowCross.scala --- @@ -0,0 +1,180 @@ +/*

[GitHub] flink pull request #2811: [FLINK-4541] Support for SQL NOT IN operator

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2811#discussion_r88434427 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/DataSetSingleRowCross.scala --- @@ -0,0 +1,158 @@ +/*

[GitHub] flink pull request #2811: [FLINK-4541] Support for SQL NOT IN operator

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2811#discussion_r88432940 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataSet/DataSetSingleRowCrossRule.scala --- @@ -0,0 +1,88 @@

[GitHub] flink pull request #2811: [FLINK-4541] Support for SQL NOT IN operator

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2811#discussion_r88434876 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/batch/sql/CalcITCase.scala --- @@ -270,6 +271,24 @@ class CalcITCase(

[GitHub] flink pull request #2811: [FLINK-4541] Support for SQL NOT IN operator

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2811#discussion_r88429682 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataSet/DataSetSingleRowCrossRule.scala --- @@ -0,0 +1,88 @@

[GitHub] flink pull request #2811: [FLINK-4541] Support for SQL NOT IN operator

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2811#discussion_r88433730 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataSet/DataSetSingleRowCrossRule.scala --- @@ -0,0 +1,88 @@

[GitHub] flink pull request #2811: [FLINK-4541] Support for SQL NOT IN operator

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2811#discussion_r88435196 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/DataSetSingleRowCross.scala --- @@ -0,0 +1,158 @@ +/*

[GitHub] flink pull request #2811: [FLINK-4541] Support for SQL NOT IN operator

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2811#discussion_r88430946 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataSet/DataSetSingleRowCrossRule.scala --- @@ -0,0 +1,88 @@

[GitHub] flink pull request #2811: [FLINK-4541] Support for SQL NOT IN operator

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2811#discussion_r88434958 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/batch/sql/JoinITCase.scala --- @@ -314,4 +315,18 @@ class JoinITCase(

[GitHub] flink pull request #2811: [Flink-4541] Support for SQL NOT IN operator

GitHub user AlexanderShoshin opened a pull request: https://github.com/apache/flink/pull/2811 [Flink-4541] Support for SQL NOT IN operator NOT IN was not working with nested queries because of missed DataSet cross join rule. I added DataSetSingleRowCrossRule that converts