[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3889#discussion_r116519646 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/SortUtil.scala --- @@ -0,0 +1,345 @@ +/* + * Licensed

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

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

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3889#discussion_r116528193 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/SortUtil.scala --- @@ -0,0 +1,345 @@ +/* + * Licensed

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3889#discussion_r116540974 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/sql/SortTest.scala --- @@ -0,0 +1,89 @@ +/* + *

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3889#discussion_r116526119 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/SortUtil.scala --- @@ -0,0 +1,345 @@ +/* + * Licensed

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3889#discussion_r116540074 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/sql/SortTest.scala --- @@ -0,0 +1,89 @@ +/* + *

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3889#discussion_r116541055 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/sql/SortTest.scala --- @@ -0,0 +1,89 @@ +/* + *

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

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

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

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

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3889#discussion_r116528048 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/SortUtil.scala --- @@ -0,0 +1,345 @@ +/* + * Licensed

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3889#discussion_r116482324 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/RowTimeSortProcessFunction.scala --- @@ -0,0 +1,169 @@

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3889#discussion_r116537188 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/sql/SortITCase.scala --- @@ -0,0 +1,133 @@ +/* + *

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3889#discussion_r116496352 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/aggregate/ProcTimeSortProcessFunctionTest.scala --- @@ -0,0 +1,165 @@

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3889#discussion_r116480310 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeSortProcessFunction.scala --- @@ -0,0 +1,127 @@

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3889#discussion_r116495740 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/RowTimeSortProcessFunction.scala --- @@ -0,0 +1,169 @@

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3889#discussion_r116495976 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/SortUtil.scala --- @@ -0,0 +1,345 @@ +/* + * Licensed

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3889#discussion_r116482718 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/RowTimeSortProcessFunction.scala --- @@ -0,0 +1,169 @@

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3889#discussion_r116521149 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/SortUtil.scala --- @@ -0,0 +1,345 @@ +/* + * Licensed

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3889#discussion_r116496006 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/SortUtil.scala --- @@ -0,0 +1,345 @@ +/* + * Licensed

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3889#discussion_r116538474 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/sql/SortITCase.scala --- @@ -0,0 +1,133 @@ +/* + *

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

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

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3889#discussion_r116483111 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeSortProcessFunction.scala --- @@ -0,0 +1,127 @@

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3889#discussion_r116490564 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/RowTimeSortProcessFunction.scala --- @@ -0,0 +1,169 @@

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3889#discussion_r116524015 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/SortUtil.scala --- @@ -0,0 +1,345 @@ +/* + * Licensed

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3889#discussion_r116526737 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/SortUtil.scala --- @@ -0,0 +1,345 @@ +/* + * Licensed

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3889#discussion_r116482838 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/RowTimeSortProcessFunction.scala --- @@ -0,0 +1,169 @@

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3889#discussion_r116518779 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/SortUtil.scala --- @@ -0,0 +1,345 @@ +/* + * Licensed

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

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

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3889#discussion_r116520149 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/SortUtil.scala --- @@ -0,0 +1,345 @@ +/* + * Licensed

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3889#discussion_r116521769 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/SortUtil.scala --- @@ -0,0 +1,345 @@ +/* + * Licensed

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3889#discussion_r116537830 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/sql/SortITCase.scala --- @@ -0,0 +1,133 @@ +/* + *

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3889#discussion_r116523262 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/SortUtil.scala --- @@ -0,0 +1,345 @@ +/* + * Licensed

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3889#discussion_r116494872 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/RowTimeSortProcessFunction.scala --- @@ -0,0 +1,169 @@

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3889#discussion_r116480335 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeSortProcessFunction.scala --- @@ -0,0 +1,127 @@

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3889#discussion_r116480769 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeSortProcessFunction.scala --- @@ -0,0 +1,127 @@

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

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

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3889#discussion_r116480397 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeSortProcessFunction.scala --- @@ -0,0 +1,127 @@

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

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

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3889#discussion_r116482918 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/RowTimeSortProcessFunction.scala --- @@ -0,0 +1,169 @@

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

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

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3889#discussion_r116481843 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/RowTimeSortProcessFunction.scala --- @@ -0,0 +1,169 @@

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

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

[jira] [Created] (FLINK-6593) Fix Bug in ProctimeAttribute or RowtimeAttribute with join UDTF

Ruidong Li created FLINK-6593: - Summary: Fix Bug in ProctimeAttribute or RowtimeAttribute with join UDTF Key: FLINK-6593 URL: https://issues.apache.org/jira/browse/FLINK-6593 Project: Flink

[jira] [Created] (FLINK-6592) RawLocalFileSystem created even if fs.hdfs.hadoopconf specified

Andrey created FLINK-6592: - Summary: RawLocalFileSystem created even if fs.hdfs.hadoopconf specified Key: FLINK-6592 URL: https://issues.apache.org/jira/browse/FLINK-6592 Project: Flink Issue Type:

[jira] [Closed] (FLINK-2593) Revisit Flink's shading policy

[ https://issues.apache.org/jira/browse/FLINK-2593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-2593. - Resolution: Duplicate Subsumed by FLINK-6529 > Revisit Flink's shading policy >

[jira] [Closed] (FLINK-2816) Memory allocation module as a separate maven artifact

[ https://issues.apache.org/jira/browse/FLINK-2816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-2816. - Resolution: Won't Fix > Memory allocation module as a separate maven artifact >

[jira] [Closed] (FLINK-5661) flink-mesos should shade its httpclient dependency away

[ https://issues.apache.org/jira/browse/FLINK-5661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-5661. - Resolution: Invalid Addressed in 63bbb4f533a0f11376834d584308e90b6b8b5f10 > flink-mesos should

[GitHub] flink issue #3908: [FLINK-5340] Document job uptime/downtime/restartTime/ful...

Github user alpinegizmo commented on the issue: https://github.com/apache/flink/pull/3908 "The time that the job has not been running in a failing/recovering situation." is confusing. How about this: The time the job has spent in a failing/recovering situation. --- If your

[jira] [Commented] (FLINK-5340) Add a metric exposing jobs uptimes

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

[jira] [Updated] (FLINK-6591) Extend functionality of final ConversionMapper

[ https://issues.apache.org/jira/browse/FLINK-6591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-6591: Affects Version/s: 1.3.0 > Extend functionality of final ConversionMapper >

[jira] [Created] (FLINK-6591) Extend functionality of final ConversionMapper

Timo Walther created FLINK-6591: --- Summary: Extend functionality of final ConversionMapper Key: FLINK-6591 URL: https://issues.apache.org/jira/browse/FLINK-6591 Project: Flink Issue Type:

[jira] [Commented] (FLINK-6440) Noisy logs from metric fetcher

[ https://issues.apache.org/jira/browse/FLINK-6440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010638#comment-16010638 ] Stephan Ewen commented on FLINK-6440: - Just logging on {{debug}} might be a reasonable first fix.

[jira] [Commented] (FLINK-6442) Extend TableAPI Support Sink Table Registration and ‘insert into’ Clause in SQL

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

[jira] [Created] (FLINK-6590) Integrate generated tables into documentation

Chesnay Schepler created FLINK-6590: --- Summary: Integrate generated tables into documentation Key: FLINK-6590 URL: https://issues.apache.org/jira/browse/FLINK-6590 Project: Flink Issue

[GitHub] flink issue #3829: [FLINK-6442] [table] Extend TableAPI Support Sink Table R...

Github user lincoln-lil commented on the issue: https://github.com/apache/flink/pull/3829 rebased on master branch --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and

[jira] [Commented] (FLINK-6370) FileAlreadyExistsException on startup

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

[GitHub] flink pull request #3896: [FLINK-6370] [webUI] Handle races for single file ...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3896#discussion_r116500253 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/files/StaticFileServerHandler.java --- @@ -234,8 +237,17 @@ private void

[jira] [Commented] (FLINK-6370) FileAlreadyExistsException on startup

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

<    1   2   3   4   5   >