[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r143400052 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamWindowJoin.scala --- @@ -184,4 +229,50 @@ class

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r143357544 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/sql/JoinITCase.scala --- @@ -102,5 +117,154 @@ class JoinITCase

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r143231150 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/sql/JoinITCase.scala --- @@ -102,5 +117,154 @@ class JoinITCase

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r143222605 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamWindowJoin.scala --- @@ -184,4 +229,50 @@ class

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r142685896 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamWindowJoin.scala --- @@ -184,4 +229,50 @@ class

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r142689196 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamWindowJoin.scala --- @@ -184,4 +229,50 @@ class

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r142682283 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamWindowJoin.scala --- @@ -152,19 +176,40 @@

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r142681690 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamWindowJoin.scala --- @@ -152,19 +176,40 @@

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r142681890 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamWindowJoin.scala --- @@ -152,19 +176,40 @@

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r142679463 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/datastream/DataStreamWindowJoinRule.scala --- @@ -105,6 +104,8 @@

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r142688996 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamWindowJoin.scala --- @@ -184,4 +229,50 @@ class

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r141993041 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala --- @@ -131,340 +116,308 @@ class

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r141831721 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala --- @@ -131,340 +116,308 @@ class

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r140645274 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala --- @@ -131,340 +116,308 @@ class

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r140266297 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala --- @@ -131,340 +116,308 @@ class

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r140262200 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala --- @@ -131,340 +116,308 @@ class

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r140251765 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala --- @@ -131,340 +116,308 @@ class

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r140197925 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala --- @@ -131,340 +116,308 @@ class

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r139986193 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/harness/JoinHarnessTest.scala --- @@ -383,13 +384,158 @@ class

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r139983961 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala --- @@ -131,340 +116,308 @@ class

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r139723927 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala --- @@ -131,340 +116,308 @@ class

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r139723011 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala --- @@ -131,340 +116,308 @@ class

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r139722338 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala --- @@ -131,340 +116,308 @@ class

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r139633281 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala --- @@ -131,340 +116,308 @@ class

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r139628583 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala --- @@ -131,340 +116,308 @@ class

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r139611419 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala --- @@ -131,340 +116,308 @@ class

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r139427057 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala --- @@ -131,340 +116,308 @@ class

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r139400962 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/harness/JoinHarnessTest.scala --- @@ -383,13 +384,158 @@ class

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r139402125 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/harness/JoinHarnessTest.scala --- @@ -383,13 +384,158 @@ class

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r139446305 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala --- @@ -131,340 +116,308 @@ class

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r139410699 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala --- @@ -131,340 +116,308 @@ class

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r139426723 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala --- @@ -131,340 +116,308 @@ class

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r139423665 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala --- @@ -131,340 +116,308 @@ class

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r139401341 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/harness/JoinHarnessTest.scala --- @@ -383,13 +384,158 @@ class

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r139435309 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala --- @@ -131,340 +116,308 @@ class

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r139399103 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamWindowJoin.scala --- @@ -166,16 +185,16 @@

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r139385852 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamWindowJoin.scala --- @@ -57,6 +61,8 @@ class

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r139401824 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/harness/JoinHarnessTest.scala --- @@ -383,13 +384,158 @@ class

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r139407531 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala --- @@ -55,18 +49,18 @@ import

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r139387007 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamWindowJoin.scala --- @@ -166,16 +185,16 @@

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r139386887 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamWindowJoin.scala --- @@ -196,53 +215,69 @@

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r139434334 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala --- @@ -131,340 +116,308 @@ class

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r139424544 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala --- @@ -131,340 +116,308 @@ class

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r139386347 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamWindowJoin.scala --- @@ -196,53 +215,69 @@

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r139386829 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamWindowJoin.scala --- @@ -196,53 +215,69 @@

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r139387143 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamWindowJoin.scala --- @@ -196,53 +215,69 @@

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r139385974 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamWindowJoin.scala --- @@ -117,6 +123,11 @@ class

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r139400726 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/harness/JoinHarnessTest.scala --- @@ -383,13 +384,158 @@ class

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r139407845 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala --- @@ -131,340 +116,308 @@ class

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r137227189 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamWindowJoin.scala --- @@ -184,4 +195,54 @@ class

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r137225735 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamWindowJoin.scala --- @@ -184,4 +195,54 @@ class

  1   2   >