[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4471 ---

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r160121422 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/util/UpdatingPlanChecker.scala --- @@ -116,14 +135,100 @@ object

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user hequn8128 commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r158489057 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamJoin.scala --- @@ -0,0 +1,207 @@ +/*

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user hequn8128 commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r158489047 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/util/UpdatingPlanChecker.scala --- @@ -116,14 +135,100 @@ object

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user hequn8128 commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r158489017 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/DataStreamInnerJoin.scala --- @@ -0,0 +1,285 @@ +/* + *

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user hequn8128 commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r158489035 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/util/UpdatingPlanChecker.scala --- @@ -116,14 +135,100 @@ object

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user hequn8128 commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r158488989 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/table/JoinITCase.scala --- @@ -0,0 +1,262 @@ +/* + *

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user hequn8128 commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r158489025 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/DataStreamInnerJoin.scala --- @@ -0,0 +1,285 @@ +/* + *

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r152818820 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/table/JoinITCase.scala --- @@ -0,0 +1,262 @@ +/* + *

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r152775960 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/DataStreamInnerJoin.scala --- @@ -0,0 +1,285 @@ +/* + *

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r152742299 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamJoin.scala --- @@ -0,0 +1,207 @@ +/* +

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r152745910 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/datastream/DataStreamJoinRule.scala --- @@ -0,0 +1,108 @@ +/*

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r152817615 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/sql/JoinITCase.scala --- @@ -414,6 +416,56 @@ class JoinITCase

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r152826859 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/util/UpdatingPlanChecker.scala --- @@ -116,14 +135,100 @@ object

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r152825553 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/util/UpdatingPlanChecker.scala --- @@ -116,14 +135,100 @@ object

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r152807064 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/DataStreamInnerJoin.scala --- @@ -0,0 +1,285 @@ +/* + *

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r152819187 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/table/JoinITCase.scala --- @@ -0,0 +1,262 @@ +/* + *

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r152830710 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/util/UpdatingPlanChecker.scala --- @@ -116,14 +135,100 @@ object

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r152819531 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/table/JoinITCase.scala --- @@ -0,0 +1,262 @@ +/* + *

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r152817360 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/sql/JoinITCase.scala --- @@ -414,6 +416,56 @@ class JoinITCase

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r152777181 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/DataStreamInnerJoin.scala --- @@ -0,0 +1,285 @@ +/* + *

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r152817078 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/sql/JoinITCase.scala --- @@ -30,6 +30,8 @@ import

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r152833454 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/util/UpdatingPlanChecker.scala --- @@ -116,14 +135,100 @@ object

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r152760126 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/DataStreamInnerJoin.scala --- @@ -0,0 +1,285 @@ +/* + *

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r152761559 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/DataStreamInnerJoin.scala --- @@ -0,0 +1,287 @@ +/* + *

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r152818061 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/table/JoinITCase.scala --- @@ -0,0 +1,262 @@ +/* + *

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r152819401 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/table/JoinITCase.scala --- @@ -0,0 +1,262 @@ +/* + *

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r152811691 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/DataStreamInnerJoin.scala --- @@ -0,0 +1,285 @@ +/* + *

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r152742134 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamJoin.scala --- @@ -0,0 +1,207 @@ +/* +

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r152753104 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/datastream/DataStreamJoinRule.scala --- @@ -0,0 +1,108 @@ +/*

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r152742893 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamJoin.scala --- @@ -0,0 +1,207 @@ +/* +

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r152773431 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/DataStreamInnerJoin.scala --- @@ -0,0 +1,285 @@ +/* + *

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r152744007 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamJoin.scala --- @@ -0,0 +1,207 @@ +/* +

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r152759465 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/CRowWrappingMultiOuputCollector.scala --- @@ -0,0 +1,50 @@ +/*

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r152753324 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/datastream/DataStreamJoinRule.scala --- @@ -0,0 +1,112 @@ +/*

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r148948528 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/datastream/DataStreamJoinRule.scala --- @@ -0,0 +1,112 @@ +/*

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r148948471 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/DataStreamInnerJoin.scala --- @@ -0,0 +1,287 @@ +/* + *

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user hequn8128 commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r148947768 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/DataStreamInnerJoin.scala --- @@ -0,0 +1,287 @@ +/* + *

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user hequn8128 commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r148947767 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/DataStreamInnerJoin.scala --- @@ -0,0 +1,287 @@ +/* + *

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user hequn8128 commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r148947760 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/datastream/DataStreamJoinRule.scala --- @@ -0,0 +1,112 @@ +/*

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user hequn8128 commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r148947758 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/util/UpdatingPlanChecker.scala --- @@ -56,16 +58,20 @@ object

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r146105057 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/CRowWrappingMultiOuputCollector.scala --- @@ -0,0 +1,48 @@ +/* +

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r146104524 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/datastream/DataStreamJoinRule.scala --- @@ -0,0 +1,112 @@ +/*

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r146104452 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamJoin.scala --- @@ -0,0 +1,211 @@ +/* + *

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r146105266 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/DataStreamInnerJoin.scala --- @@ -0,0 +1,287 @@ +/* + *

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r146105104 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/DataStreamInnerJoin.scala --- @@ -0,0 +1,287 @@ +/* + *

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r146105359 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/DataStreamInnerJoin.scala --- @@ -0,0 +1,287 @@ +/* + *

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r146105512 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/DataStreamInnerJoin.scala --- @@ -0,0 +1,287 @@ +/* + *

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r146104323 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamJoin.scala --- @@ -0,0 +1,211 @@ +/* + *

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r146104539 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/datastream/DataStreamJoinRule.scala --- @@ -0,0 +1,112 @@ +/*

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r146104726 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/util/UpdatingPlanChecker.scala --- @@ -56,16 +58,20 @@ object

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r143394582 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/datastream/DataStreamJoinRule.scala --- @@ -0,0 +1,93 @@ +/*

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user hequn8128 commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r143320024 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/datastream/DataStreamJoinRule.scala --- @@ -0,0 +1,93 @@ +/*

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r142779879 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/datastream/DataStreamJoinRule.scala --- @@ -0,0 +1,93 @@ +/*

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user shaoxuan-wang commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r140951770 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/datastream/DataStreamJoinRule.scala --- @@ -0,0 +1,93 @@

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r132468046 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/util/UpdatingPlanChecker.scala --- @@ -56,17 +59,20 @@ object

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r132307133 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/plan/UpdatingPlanCheckerTest.scala --- @@ -0,0 +1,203 @@ +/* + *

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r132284969 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/ProcTimeNonWindowInnerJoin.scala --- @@ -0,0 +1,275 @@ +/*

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r132303211 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/stream/table/validation/JoinValidationTest.scala --- @@ -0,0 +1,112 @@

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r132243950 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/util/UpdatingPlanChecker.scala --- @@ -90,40 +96,86 @@ object

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r132213679 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamJoin.scala --- @@ -0,0 +1,212 @@ +/* +

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r132470085 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/plan/UpdatingPlanCheckerTest.scala --- @@ -0,0 +1,203 @@ +/* + *

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r132306504 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/ProcTimeNonWindowInnerJoin.scala --- @@ -0,0 +1,275 @@ +/*

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r13228 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamJoin.scala --- @@ -0,0 +1,212 @@ +/* +

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r132305360 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/plan/UpdatingPlanCheckerTest.scala --- @@ -0,0 +1,203 @@ +/* + *

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r132421076 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/harness/JoinHarnessTest.scala --- @@ -232,4 +238,111 @@ class

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r132227802 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/util/UpdatingPlanChecker.scala --- @@ -37,8 +37,11 @@ object

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r132305574 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/plan/UpdatingPlanCheckerTest.scala --- @@ -0,0 +1,203 @@ +/* + *

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r132298846 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/ProcTimeNonWindowInnerJoin.scala --- @@ -0,0 +1,275 @@ +/*

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r132229636 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/util/UpdatingPlanChecker.scala --- @@ -56,17 +59,20 @@ object

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r132446011 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/table/TableSinkITCase.scala --- @@ -506,4 +467,43 @@ object

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r132277678 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/util/UpdatingPlanChecker.scala --- @@ -90,40 +96,86 @@ object

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r132422891 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/harness/JoinHarnessTest.scala --- @@ -232,4 +238,111 @@ class

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r132302597 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/ProcTimeNonWindowInnerJoin.scala --- @@ -0,0 +1,275 @@ +/*

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r132441331 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/sql/JoinITCase.scala --- @@ -102,5 +103,51 @@ class JoinITCase

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r132456285 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/util/UpdatingPlanChecker.scala --- @@ -90,40 +96,86 @@ object

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r132230160 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/util/UpdatingPlanChecker.scala --- @@ -56,17 +59,20 @@ object

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r132458139 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/util/UpdatingPlanChecker.scala --- @@ -90,40 +96,86 @@ object

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r132212670 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamJoin.scala --- @@ -0,0 +1,212 @@ +/* +

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r132412037 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/plan/UpdatingPlanCheckerTest.scala --- @@ -0,0 +1,203 @@ +/* + *

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r132300742 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/ProcTimeNonWindowInnerJoin.scala --- @@ -0,0 +1,275 @@ +/*

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r132306893 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/plan/UpdatingPlanCheckerTest.scala --- @@ -0,0 +1,203 @@ +/* + *

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r132302566 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/ProcTimeNonWindowInnerJoin.scala --- @@ -0,0 +1,275 @@ +/*

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r132238828 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/util/UpdatingPlanChecker.scala --- @@ -90,40 +96,86 @@ object

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r132228222 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/util/UpdatingPlanChecker.scala --- @@ -90,40 +96,86 @@ object

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r132456337 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/util/UpdatingPlanChecker.scala --- @@ -90,40 +96,86 @@ object

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r132284044 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/ProcTimeNonWindowInnerJoin.scala --- @@ -0,0 +1,275 @@ +/*

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r132300560 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/ProcTimeNonWindowInnerJoin.scala --- @@ -0,0 +1,275 @@ +/*

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r132230387 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/util/UpdatingPlanChecker.scala --- @@ -56,17 +59,20 @@ object

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r132242877 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/util/UpdatingPlanChecker.scala --- @@ -90,40 +96,86 @@ object

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r132305698 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/plan/UpdatingPlanCheckerTest.scala --- @@ -0,0 +1,203 @@ +/* + *

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r132235747 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/util/UpdatingPlanChecker.scala --- @@ -90,40 +96,86 @@ object

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r132303241 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/stream/table/validation/JoinValidationTest.scala --- @@ -0,0 +1,112 @@

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r132300021 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/ProcTimeNonWindowInnerJoin.scala --- @@ -0,0 +1,275 @@ +/*

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r132229209 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/util/UpdatingPlanChecker.scala --- @@ -90,40 +96,86 @@ object

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r132210266 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamJoin.scala --- @@ -0,0 +1,212 @@ +/* +

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r13231 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/ProcTimeNonWindowInnerJoin.scala --- @@ -0,0 +1,275 @@ +/*

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r132424191 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/ProcTimeNonWindowInnerJoin.scala --- @@ -0,0 +1,275 @@ +/*

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r132233953 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/util/UpdatingPlanChecker.scala --- @@ -90,40 +96,86 @@ object

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r132300708 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/ProcTimeNonWindowInnerJoin.scala --- @@ -0,0 +1,275 @@ +/*

  1   2   >