[jira] [Commented] (FLINK-6336) Placement Constraints for Mesos

[ https://issues.apache.org/jira/browse/FLINK-6336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15978311#comment-15978311 ] ASF GitHub Bot commented on FLINK-6336: --- GitHub user sgran reopened a pull request:

[GitHub] flink pull request #3744: [FLINK-6336] Initial commit of mesos placement con...

Github user sgran closed the pull request at: https://github.com/apache/flink/pull/3744 --- 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 wishes so, or if the feature is enabl

[GitHub] flink pull request #3744: [FLINK-6336] Initial commit of mesos placement con...

GitHub user sgran reopened a pull request: https://github.com/apache/flink/pull/3744 [FLINK-6336] Initial commit of mesos placement constraints This adds a HostAttrValueConstraint evaluator for fenzo, allowing tasks to be placed on agents with matching attributes. Signed

[jira] [Commented] (FLINK-6288) FlinkKafkaProducer's custom Partitioner is always invoked with number of partitions of default topic

[ https://issues.apache.org/jira/browse/FLINK-6288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15978308#comment-15978308 ] Tzu-Li (Gordon) Tai commented on FLINK-6288: Sure, please go ahead. And thanks

[jira] [Commented] (FLINK-6288) FlinkKafkaProducer's custom Partitioner is always invoked with number of partitions of default topic

[ https://issues.apache.org/jira/browse/FLINK-6288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15978304#comment-15978304 ] Fang Yong commented on FLINK-6288: -- Hi [~tzulitai], I'll pick this issue if nobody follow

[jira] [Commented] (FLINK-6176) Add JARs to CLASSPATH deterministically

[ https://issues.apache.org/jira/browse/FLINK-6176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15978300#comment-15978300 ] ASF GitHub Bot commented on FLINK-6176: --- Github user StephanEwen commented on the is

[GitHub] flink issue #3632: [FLINK-6176] [scripts] Add JARs to CLASSPATH deterministi...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3632 Changes look good to me. Merging this... --- 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

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

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

[GitHub] flink pull request #3743: [FLINK-6228][table] Integrating the OVER windows i...

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

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

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

[GitHub] flink pull request #3743: [FLINK-6228][table] Integrating the OVER windows i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3743#discussion_r112636652 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/logical/operators.scala --- @@ -54,6 +54,9 @@ case class Project(projectLis

[jira] [Commented] (FLINK-5758) Port-range for the web interface via YARN

[ https://issues.apache.org/jira/browse/FLINK-5758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15978295#comment-15978295 ] ASF GitHub Bot commented on FLINK-5758: --- Github user StephanEwen commented on the is

[GitHub] flink issue #3391: [FLINK-5758] [yarn] support port range for web monitor

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3391 @barcahead Please let us know if you want to follow up on this PR... --- 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 projec

[jira] [Commented] (FLINK-5918) port range support for config taskmanager.rpc.port

[ https://issues.apache.org/jira/browse/FLINK-5918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15978290#comment-15978290 ] ASF GitHub Bot commented on FLINK-5918: --- Github user StephanEwen commented on the is

[GitHub] flink issue #3416: [FLINK-5918] [runtime] port range support for config task...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3416 @zentol Has this been merged? --- 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 an

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

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

[GitHub] flink pull request #3743: [FLINK-6228][table] Integrating the OVER windows i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3743#discussion_r112635892 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/call.scala --- @@ -49,6 +57,128 @@ case class Call(functionName: Str

[GitHub] flink issue #3749: Typo sick -> sink

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3749 Good fix, funny typo ;-) Merging this... --- 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 thi

[jira] [Commented] (FLINK-5623) TempBarrier dam has been closed

[ https://issues.apache.org/jira/browse/FLINK-5623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15978281#comment-15978281 ] ASF GitHub Bot commented on FLINK-5623: --- Github user StephanEwen commented on the is

[GitHub] flink issue #3747: [FLINK-5623] [runtime] Fix TempBarrier dam has been close...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3747 Merging this... --- 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 wishes so, o

[jira] [Commented] (FLINK-6217) ContaineredTaskManagerParameters sets off heap memory size incorrectly

[ https://issues.apache.org/jira/browse/FLINK-6217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15978276#comment-15978276 ] ASF GitHub Bot commented on FLINK-6217: --- Github user StephanEwen commented on the is

[GitHub] flink issue #3648: [FLINK-6217] ContaineredTaskManagerParameters sets off-he...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3648 Good fix, thanks @haohui I was wondering - I am a trying to advocate fewer dependencies in Flink (there is always the problem of shading and conflicts) so if there is a way to do this w

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

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

[GitHub] flink pull request #3743: [FLINK-6228][table] Integrating the OVER windows i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3743#discussion_r112633124 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/call.scala --- @@ -49,6 +57,128 @@ case class Call(functionName: Str

[jira] [Commented] (FLINK-4562) table examples make an divided module in flink-examples

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

[GitHub] flink issue #2460: [FLINK-4562] table examples make an divided module in fli...

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2460 Thanks, @shijinkui I think this PR is good to merge. I was waiting for you to add the examples jar file to the `./opt` folder, but we can also do this as a follow up task. I'll rename th

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

[ https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15978257#comment-15978257 ] ASF GitHub Bot commented on FLINK-6228: --- Github user sunjincheng121 commented on a d

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

[ https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15978256#comment-15978256 ] ASF GitHub Bot commented on FLINK-6228: --- Github user sunjincheng121 commented on a d

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

[ https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15978253#comment-15978253 ] ASF GitHub Bot commented on FLINK-6228: --- Github user sunjincheng121 commented on a d

[GitHub] flink pull request #3743: [FLINK-6228][table] Integrating the OVER windows i...

Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/3743#discussion_r112628642 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/logical/operators.scala --- @@ -54,6 +54,9 @@ case class Project(pro

[GitHub] flink pull request #3743: [FLINK-6228][table] Integrating the OVER windows i...

Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/3743#discussion_r112605911 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/windows.scala --- @@ -22,6 +22,126 @@ import org.apache.flink.table.e

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

[ https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15978254#comment-15978254 ] ASF GitHub Bot commented on FLINK-6228: --- Github user sunjincheng121 commented on a d

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

[ https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15978255#comment-15978255 ] ASF GitHub Bot commented on FLINK-6228: --- Github user sunjincheng121 commented on a d

[GitHub] flink pull request #3743: [FLINK-6228][table] Integrating the OVER windows i...

Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/3743#discussion_r112620324 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/call.scala --- @@ -49,6 +57,128 @@ case class Call(functionNa

[GitHub] flink pull request #3743: [FLINK-6228][table] Integrating the OVER windows i...

Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/3743#discussion_r112604758 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/table/OverWindowITCase.scala --- @@ -0,0 +1,265 @@ +

[GitHub] flink pull request #3743: [FLINK-6228][table] Integrating the OVER windows i...

Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/3743#discussion_r112628964 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/call.scala --- @@ -49,6 +57,128 @@ case class Call(functionNa

[jira] [Closed] (FLINK-6103) LocalFileSystem rename() uses File.renameTo()

[ https://issues.apache.org/jira/browse/FLINK-6103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-6103. --- > LocalFileSystem rename() uses File.renameTo() > - > >

[jira] [Commented] (FLINK-6103) LocalFileSystem rename() uses File.renameTo()

[ https://issues.apache.org/jira/browse/FLINK-6103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15978252#comment-15978252 ] ASF GitHub Bot commented on FLINK-6103: --- Github user asfgit closed the pull request

[jira] [Resolved] (FLINK-6103) LocalFileSystem rename() uses File.renameTo()

[ https://issues.apache.org/jira/browse/FLINK-6103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-6103. - Resolution: Fixed Fix Version/s: 1.3.0 Fixed via a4f9a54953132fbd1a44888a403576c157649f1f a

[GitHub] flink pull request #3598: [FLINK-6103] LocalFileSystem rename() uses File.re...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3598 --- 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 wishes so, or if the feature is enab

[GitHub] flink pull request #3749: Typo sick -> sink

GitHub user marctrem opened a pull request: https://github.com/apache/flink/pull/3749 Typo sick -> sink Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration. If your changes take all of the items into

[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&focusedCommentId=15978206#comment-15978206 ] ASF GitHub Bot commented on FLINK-6075: --- Github user rtudoran commented on a diff in

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

Github user rtudoran commented on a diff in the pull request: https://github.com/apache/flink/pull/3714#discussion_r112623715 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/SortUtil.scala --- @@ -0,0 +1,353 @@ +/* + * 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&focusedCommentId=15978203#comment-15978203 ] ASF GitHub Bot commented on FLINK-6075: --- Github user rtudoran commented on a diff in

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

Github user rtudoran commented on a diff in the pull request: https://github.com/apache/flink/pull/3714#discussion_r112623603 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/SortUtil.scala --- @@ -0,0 +1,353 @@ +/* + * 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&focusedCommentId=15978198#comment-15978198 ] ASF GitHub Bot commented on FLINK-6075: --- Github user rtudoran commented on a diff in

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

Github user rtudoran commented on a diff in the pull request: https://github.com/apache/flink/pull/3714#discussion_r112623175 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamSort.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&focusedCommentId=15978195#comment-15978195 ] ASF GitHub Bot commented on FLINK-6075: --- Github user rtudoran commented on a diff in

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

Github user rtudoran commented on a diff in the pull request: https://github.com/apache/flink/pull/3714#discussion_r112623029 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamSort.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&focusedCommentId=15978190#comment-15978190 ] ASF GitHub Bot commented on FLINK-6075: --- Github user rtudoran commented on a diff in

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

Github user rtudoran commented on a diff in the pull request: https://github.com/apache/flink/pull/3714#discussion_r112622475 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamSort.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&focusedCommentId=15978185#comment-15978185 ] ASF GitHub Bot commented on FLINK-6075: --- Github user rtudoran commented on a diff in

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

Github user rtudoran commented on a diff in the pull request: https://github.com/apache/flink/pull/3714#discussion_r112622144 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/datastream/DataStreamSortRule.scala --- @@ -0,0 +1,67 @@ +/*

<    1   2   3   4