[jira] [Created] (FLINK-7591) Support partition by and order by of MATCH_RECOGNIZE

Dian Fu created FLINK-7591: -- Summary: Support partition by and order by of MATCH_RECOGNIZE Key: FLINK-7591 URL: https://issues.apache.org/jira/browse/FLINK-7591 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154802#comment-16154802 ] Shuyi Chen commented on FLINK-7491: --- Thanks a lot, [~fhueske]. > Support COLLECT Aggregate function in

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154789#comment-16154789 ] ASF GitHub Bot commented on FLINK-6233: --- Github user xccui commented on a diff in the pull request:

[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_r137168799 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala --- @@ -0,0 +1,533 @@ +/* +

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154753#comment-16154753 ] ASF GitHub Bot commented on FLINK-6233: --- Github user xccui commented on a diff in the pull request:

[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_r137163327 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala --- @@ -0,0 +1,533 @@ +/* +

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154719#comment-16154719 ] ASF GitHub Bot commented on FLINK-6233: --- Github user xccui commented on a diff in the pull request:

[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_r137158818 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala --- @@ -0,0 +1,533 @@ +/* +

[jira] [Commented] (FLINK-7310) always use HybridMemorySegment

[ https://issues.apache.org/jira/browse/FLINK-7310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154711#comment-16154711 ] ASF GitHub Bot commented on FLINK-7310: --- Github user KurtYoung commented on the issue:

[GitHub] flink issue #4445: [FLINK-7310][core] always use the HybridMemorySegment

Github user KurtYoung commented on the issue: https://github.com/apache/flink/pull/4445 I would bet on deserialization for it. And why sorter suffers more regression than hash join is that sorter will cause more deserializations during compare records than hash join. Despite

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154655#comment-16154655 ] ASF GitHub Bot commented on FLINK-6233: --- Github user xccui commented on a diff in the pull request:

[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_r137150128 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/WindowJoinUtil.scala --- @@ -115,10 +118,15 @@ object WindowJoinUtil

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154622#comment-16154622 ] ASF GitHub Bot commented on FLINK-6233: --- Github user xccui commented on a diff in the pull request:

[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_r137146303 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamWindowJoin.scala --- @@ -184,4 +195,54 @@ class

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154604#comment-16154604 ] ASF GitHub Bot commented on FLINK-6233: --- Github user xccui commented on a diff in the pull request:

[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_r137144634 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamWindowJoin.scala --- @@ -184,4 +195,54 @@ class

[jira] [Commented] (FLINK-7439) Support variable arguments for UDTF in SQL

[ https://issues.apache.org/jira/browse/FLINK-7439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154594#comment-16154594 ] ASF GitHub Bot commented on FLINK-7439: --- Github user sunjincheng121 commented on the issue:

[GitHub] flink issue #4536: [FLINK-7439] [table] Support variable arguments for UDTF ...

Github user sunjincheng121 commented on the issue: https://github.com/apache/flink/pull/4536 Thanks for the updating, looks good to me. +1 to merged. ---

[jira] [Commented] (FLINK-6465) support FIRST_VALUE on Table API & SQL

[ https://issues.apache.org/jira/browse/FLINK-6465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154583#comment-16154583 ] ASF GitHub Bot commented on FLINK-6465: --- Github user sunjincheng121 commented on a diff in the pull

[GitHub] flink pull request #4556: [FLINK-6465][table]support FIRST_VALUE on Table AP...

Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4556#discussion_r137142537 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/FirstValueAggFunctionWithRetract.scala --- @@

[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_r137137915 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/datastream/DataStreamWindowJoinRule.scala --- @@ -55,8 +55,10 @@ class

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154540#comment-16154540 ] ASF GitHub Bot commented on FLINK-6233: --- Github user xccui commented on a diff in the pull request:

[GitHub] flink issue #4625: [FLINK-6233] [table] Support time-bounded stream inner jo...

Github user xccui commented on the issue: https://github.com/apache/flink/pull/4625 Thanks for the review, @fhueske. This PR is a little rough when I committed. I'll address your comments and submit a refined version as soon as possible. Best, Xingcan ---

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154530#comment-16154530 ] ASF GitHub Bot commented on FLINK-6233: --- Github user xccui commented on the issue:

[jira] [Updated] (FLINK-7590) Flink failed to flush and close the file system output stream for checkpointing because of s3 read timeout

[ https://issues.apache.org/jira/browse/FLINK-7590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-7590: Summary: Flink failed to flush and close the file system output stream for checkpointing because of s3 read

[jira] [Created] (FLINK-7590) Flink failed to flush and close the file system output stream for checkpointing

Bowen Li created FLINK-7590: --- Summary: Flink failed to flush and close the file system output stream for checkpointing Key: FLINK-7590 URL: https://issues.apache.org/jira/browse/FLINK-7590 Project: Flink

[jira] [Created] (FLINK-7589) org.apache.http.ConnectionClosedException: Premature end of Content-Length delimited message body (expected: 159764230; received: 64638536)

Bowen Li created FLINK-7589: --- Summary: org.apache.http.ConnectionClosedException: Premature end of Content-Length delimited message body (expected: 159764230; received: 64638536) Key: FLINK-7589 URL:

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154413#comment-16154413 ] ASF GitHub Bot commented on FLINK-6233: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154417#comment-16154417 ] ASF GitHub Bot commented on FLINK-6233: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154405#comment-16154405 ] ASF GitHub Bot commented on FLINK-6233: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154422#comment-16154422 ] ASF GitHub Bot commented on FLINK-6233: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154412#comment-16154412 ] ASF GitHub Bot commented on FLINK-6233: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154424#comment-16154424 ] ASF GitHub Bot commented on FLINK-6233: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154416#comment-16154416 ] ASF GitHub Bot commented on FLINK-6233: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154421#comment-16154421 ] ASF GitHub Bot commented on FLINK-6233: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154419#comment-16154419 ] ASF GitHub Bot commented on FLINK-6233: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154393#comment-16154393 ] ASF GitHub Bot commented on FLINK-6233: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154395#comment-16154395 ] ASF GitHub Bot commented on FLINK-6233: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154415#comment-16154415 ] ASF GitHub Bot commented on FLINK-6233: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154381#comment-16154381 ] ASF GitHub Bot commented on FLINK-6233: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154402#comment-16154402 ] ASF GitHub Bot commented on FLINK-6233: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154379#comment-16154379 ] ASF GitHub Bot commented on FLINK-6233: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154404#comment-16154404 ] ASF GitHub Bot commented on FLINK-6233: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154396#comment-16154396 ] ASF GitHub Bot commented on FLINK-6233: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154420#comment-16154420 ] ASF GitHub Bot commented on FLINK-6233: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154411#comment-16154411 ] ASF GitHub Bot commented on FLINK-6233: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154400#comment-16154400 ] ASF GitHub Bot commented on FLINK-6233: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154423#comment-16154423 ] ASF GitHub Bot commented on FLINK-6233: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154414#comment-16154414 ] ASF GitHub Bot commented on FLINK-6233: --- Github user fhueske commented on a diff in the pull

[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_r137110758 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala --- @@ -0,0 +1,533 @@ +/*

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154418#comment-16154418 ] ASF GitHub Bot commented on FLINK-6233: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154407#comment-16154407 ] ASF GitHub Bot commented on FLINK-6233: --- Github user fhueske commented on a diff in the pull

[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_r137099832 --- 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_r137040219 --- 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_r137095404 --- 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_r137098896 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala --- @@ -0,0 +1,533 @@ +/*

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154397#comment-16154397 ] ASF GitHub Bot commented on FLINK-6233: --- Github user fhueske commented on a diff in the pull

[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_r137096261 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala --- @@ -0,0 +1,533 @@ +/*

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154383#comment-16154383 ] ASF GitHub Bot commented on FLINK-6233: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154406#comment-16154406 ] ASF GitHub Bot commented on FLINK-6233: --- Github user fhueske commented on a diff in the pull

[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_r137112342 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala --- @@ -0,0 +1,533 @@ +/*

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154403#comment-16154403 ] ASF GitHub Bot commented on FLINK-6233: --- Github user fhueske commented on a diff in the pull

[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_r137039075 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala --- @@ -0,0 +1,533 @@ +/*

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154391#comment-16154391 ] ASF GitHub Bot commented on FLINK-6233: --- Github user fhueske commented on a diff in the pull

[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_r137040050 --- 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_r137038607 --- 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_r137117454 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala --- @@ -0,0 +1,533 @@ +/*

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154408#comment-16154408 ] ASF GitHub Bot commented on FLINK-6233: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154389#comment-16154389 ] ASF GitHub Bot commented on FLINK-6233: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154392#comment-16154392 ] ASF GitHub Bot commented on FLINK-6233: --- Github user fhueske commented on a diff in the pull

[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_r137031980 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/WindowJoinUtil.scala --- @@ -115,10 +118,15 @@ object

[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_r137035608 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala --- @@ -0,0 +1,533 @@ +/*

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154380#comment-16154380 ] ASF GitHub Bot commented on FLINK-6233: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154388#comment-16154388 ] ASF GitHub Bot commented on FLINK-6233: --- Github user fhueske commented on a diff in the pull

[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_r137013584 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamWindowJoin.scala --- @@ -184,4 +195,54 @@ class

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154386#comment-16154386 ] ASF GitHub Bot commented on FLINK-6233: --- Github user fhueske commented on a diff in the pull

[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_r137038433 --- 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_r137041142 --- 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_r137037638 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala --- @@ -0,0 +1,533 @@ +/*

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154387#comment-16154387 ] ASF GitHub Bot commented on FLINK-6233: --- Github user fhueske commented on a diff in the pull

[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_r137100691 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala --- @@ -0,0 +1,533 @@ +/*

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154399#comment-16154399 ] ASF GitHub Bot commented on FLINK-6233: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154394#comment-16154394 ] ASF GitHub Bot commented on FLINK-6233: --- Github user fhueske commented on a diff in the pull

[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_r137120634 --- 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_r137108027 --- 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_r137014641 --- 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_r137113304 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala --- @@ -0,0 +1,533 @@ +/*

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154382#comment-16154382 ] ASF GitHub Bot commented on FLINK-6233: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154410#comment-16154410 ] ASF GitHub Bot commented on FLINK-6233: --- Github user fhueske commented on a diff in the pull

[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_r137040311 --- 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_r137010384 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/datastream/DataStreamWindowJoinRule.scala --- @@ -55,8 +55,10 @@

[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_r137020297 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/WindowJoinUtil.scala --- @@ -39,14 +39,17 @@ import

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154390#comment-16154390 ] ASF GitHub Bot commented on FLINK-6233: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154409#comment-16154409 ] ASF GitHub Bot commented on FLINK-6233: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154401#comment-16154401 ] ASF GitHub Bot commented on FLINK-6233: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154398#comment-16154398 ] ASF GitHub Bot commented on FLINK-6233: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154384#comment-16154384 ] ASF GitHub Bot commented on FLINK-6233: --- Github user fhueske commented on a diff in the pull

[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_r137092951 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala --- @@ -0,0 +1,533 @@ +/*

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154378#comment-16154378 ] ASF GitHub Bot commented on FLINK-6233: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154385#comment-16154385 ] ASF GitHub Bot commented on FLINK-6233: --- Github user fhueske commented on a diff in the pull

  1   2   3   >