[jira] [Comment Edited] (FLINK-6997) SavepointITCase fails in master branch sometimes

[ https://issues.apache.org/jira/browse/FLINK-6997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16061814#comment-16061814 ] mingleizhang edited comment on FLINK-6997 at 6/24/17 5:51 AM: -- I tested

[jira] [Commented] (FLINK-6997) SavepointITCase fails in master branch sometimes

[ https://issues.apache.org/jira/browse/FLINK-6997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16061814#comment-16061814 ] mingleizhang commented on FLINK-6997: - I tested several times and occasionally failed. But what i got

[jira] [Updated] (FLINK-6997) SavepointITCase fails in master branch sometimes

[ https://issues.apache.org/jira/browse/FLINK-6997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-6997: -- Summary: SavepointITCase fails in master branch sometimes (was: SavepointITCase fails in master branch) >

[jira] [Commented] (FLINK-5695) Optimize table type systems based on database semantics

[ https://issues.apache.org/jira/browse/FLINK-5695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16061625#comment-16061625 ] ASF GitHub Bot commented on FLINK-5695: --- Github user sunjincheng121 closed the pull request at:

[GitHub] flink pull request #3248: [FLINK-5695] [Table API & SQL] Optimize table type...

Github user sunjincheng121 closed the pull request at: https://github.com/apache/flink/pull/3248 --- 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

[jira] [Commented] (FLINK-6916) FLIP-19: Improved BLOB storage architecture

[ https://issues.apache.org/jira/browse/FLINK-6916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16061567#comment-16061567 ] ASF GitHub Bot commented on FLINK-6916: --- GitHub user NicoK opened a pull request:

[GitHub] flink pull request #4176: [FLINK-6916][blob] add API to allow job-related BL...

GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/4176 [FLINK-6916][blob] add API to allow job-related BLOBs to be stored This PR is the fourth in a series for FLIP-19, based upon #4174. It allows (CONTENT_ADDRESSABLE) BLOBs to not only be stored

[jira] [Commented] (FLINK-6958) Async I/O timeout not work

[ https://issues.apache.org/jira/browse/FLINK-6958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16061517#comment-16061517 ] Till Rohrmann commented on FLINK-6958: --

[jira] [Updated] (FLINK-6998) Kafka connector needs to expose metrics for failed/successful offset commits in the Kafka Consumer callback

[ https://issues.apache.org/jira/browse/FLINK-6998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenzhong Xu updated FLINK-6998: Description: Propose to add "successful-commits" and "failed-commits" metrics in

[jira] [Created] (FLINK-6998) Kafka connector needs to expose metrics for failed/successful offset commits in the Kafka Consumer callback

Zhenzhong Xu created FLINK-6998: --- Summary: Kafka connector needs to expose metrics for failed/successful offset commits in the Kafka Consumer callback Key: FLINK-6998 URL:

[jira] [Commented] (FLINK-6379) Implement FLIP-6 Mesos Resource Manager

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

[jira] [Assigned] (FLINK-6998) Kafka connector needs to expose metrics for failed/successful offset commits in the Kafka Consumer callback

[ https://issues.apache.org/jira/browse/FLINK-6998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenzhong Xu reassigned FLINK-6998: --- Assignee: Zhenzhong Xu > Kafka connector needs to expose metrics for failed/successful

[GitHub] flink issue #3942: FLINK-6379 Mesos ResourceManager (FLIP-6)

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/3942 Sorry for the long delay Eron. I've started reviewing the code last week. I'm not completely done yet, but so far things look good. As a follow up we could think about how we can remove the

[jira] [Created] (FLINK-6997) SavepointITCase fails in master branch

Ted Yu created FLINK-6997: - Summary: SavepointITCase fails in master branch Key: FLINK-6997 URL: https://issues.apache.org/jira/browse/FLINK-6997 Project: Flink Issue Type: Bug Components:

[GitHub] flink issue #4167: Test PR, please ignore

Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4167 I'm working on a PR to print some system information (with output folding) to the TravisCI log which may be useful in debugging these sort of changes. It would be nice if we could fold each Maven

[jira] [Commented] (FLINK-6855) Add handler for taking a savepoint

[ https://issues.apache.org/jira/browse/FLINK-6855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16061320#comment-16061320 ] Eron Wright commented on FLINK-6855: - Is this related to FLINK-4336? > Add handler for taking a

[GitHub] flink issue #4167: Test PR, please ignore

Github user zentol commented on the issue: https://github.com/apache/flink/pull/4167 This PR stabilized build times around 55 minutes. While we are not below 50 yet we can still tweak some stuff, so I propose merging it (after re-enabling RAT of course) and go from there.

[jira] [Commented] (FLINK-6964) Fix recovery for incremental checkpoints in StandaloneCompletedCheckpointStore

[ https://issues.apache.org/jira/browse/FLINK-6964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16061291#comment-16061291 ] Stefan Richter commented on FLINK-6964: --- Those placeholder messages look ok and expected, that

[jira] [Commented] (FLINK-6964) Fix recovery for incremental checkpoints in StandaloneCompletedCheckpointStore

[ https://issues.apache.org/jira/browse/FLINK-6964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16061270#comment-16061270 ] Cliff Resnick commented on FLINK-6964: -- looks likes it's still trying to register a Placeholder? >

[jira] [Commented] (FLINK-6964) Fix recovery for incremental checkpoints in StandaloneCompletedCheckpointStore

[ https://issues.apache.org/jira/browse/FLINK-6964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16061257#comment-16061257 ] Cliff Resnick commented on FLINK-6964: -- I ran with your newer precondition. It actually succeeded

[jira] [Commented] (FLINK-6964) Fix recovery for incremental checkpoints in StandaloneCompletedCheckpointStore

[ https://issues.apache.org/jira/browse/FLINK-6964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16061216#comment-16061216 ] Cliff Resnick commented on FLINK-6964: -- ok, will try that. meanwhile here is a run (and hang) from

[jira] [Commented] (FLINK-6971) Add Alluxio Filesystem in Flink Ecosystem page

[ https://issues.apache.org/jira/browse/FLINK-6971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16061208#comment-16061208 ] Bin Fan commented on FLINK-6971: Thanks [~fhueske], I will read the instructions and get back to here if

[jira] [Commented] (FLINK-6971) Add Alluxio Filesystem in Flink Ecosystem page

[ https://issues.apache.org/jira/browse/FLINK-6971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16061204#comment-16061204 ] Fabian Hueske commented on FLINK-6971: -- Hi [~apc999], yes a PR would be very much appreciated. You

[jira] [Commented] (FLINK-6971) Add Alluxio Filesystem in Flink Ecosystem page

[ https://issues.apache.org/jira/browse/FLINK-6971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16061191#comment-16061191 ] Bin Fan commented on FLINK-6971: Anyone to comment? Is this the recommended way? thanks > Add Alluxio

[jira] [Commented] (FLINK-6964) Fix recovery for incremental checkpoints in StandaloneCompletedCheckpointStore

[ https://issues.apache.org/jira/browse/FLINK-6964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16061190#comment-16061190 ] Stefan Richter commented on FLINK-6964: --- Alright, it wasn't the precondition. I have pushed the

[jira] [Commented] (FLINK-6964) Fix recovery for incremental checkpoints in StandaloneCompletedCheckpointStore

[ https://issues.apache.org/jira/browse/FLINK-6964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16061178#comment-16061178 ] Cliff Resnick commented on FLINK-6964: -- ok I'll wait on your push > Fix recovery for incremental

[jira] [Commented] (FLINK-6964) Fix recovery for incremental checkpoints in StandaloneCompletedCheckpointStore

[ https://issues.apache.org/jira/browse/FLINK-6964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16061174#comment-16061174 ] Stefan Richter commented on FLINK-6964: --- I think I already found the problem. A stupid mistake: the

[jira] [Comment Edited] (FLINK-6996) FlinkKafkaProducer010 doesn't guarantee at-least-once semantic

[ https://issues.apache.org/jira/browse/FLINK-6996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16061168#comment-16061168 ] Piotr Nowojski edited comment on FLINK-6996 at 6/23/17 4:20 PM: Yes,

[jira] [Updated] (FLINK-6996) FlinkKafkaProducer010 doesn't guarantee at-least-once semantic

[ https://issues.apache.org/jira/browse/FLINK-6996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-6996: -- Description: FlinkKafkaProducer010 doesn't implement CheckpointedFunction interface. This

[jira] [Commented] (FLINK-6996) FlinkKafkaProducer010 doesn't guarantee at-least-once semantic

[ https://issues.apache.org/jira/browse/FLINK-6996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16061168#comment-16061168 ] Piotr Nowojski commented on FLINK-6996: --- Yes, you are correct. Fixed description. >

[jira] [Commented] (FLINK-6964) Fix recovery for incremental checkpoints in StandaloneCompletedCheckpointStore

[ https://issues.apache.org/jira/browse/FLINK-6964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16061166#comment-16061166 ] Stefan Richter commented on FLINK-6964: --- In particular, JobManager logs are valuable. > Fix

[jira] [Commented] (FLINK-6964) Fix recovery for incremental checkpoints in StandaloneCompletedCheckpointStore

[ https://issues.apache.org/jira/browse/FLINK-6964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16061164#comment-16061164 ] Stefan Richter commented on FLINK-6964: --- I suggest to log Flink runtime at INFO level, thanks! :-)

[jira] [Commented] (FLINK-6964) Fix recovery for incremental checkpoints in StandaloneCompletedCheckpointStore

[ https://issues.apache.org/jira/browse/FLINK-6964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16061163#comment-16061163 ] Cliff Resnick commented on FLINK-6964: -- Ha! I just started running. ok, will merge and rebuild The

[jira] [Commented] (FLINK-6964) Fix recovery for incremental checkpoints in StandaloneCompletedCheckpointStore

[ https://issues.apache.org/jira/browse/FLINK-6964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16061143#comment-16061143 ] Stefan Richter commented on FLINK-6964: --- I have added a commit to my branch that introduces more

[jira] [Commented] (FLINK-6885) RMQSource does not support qos, leading to oom

[ https://issues.apache.org/jira/browse/FLINK-6885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16061130#comment-16061130 ] Fabian Hueske commented on FLINK-6885: -- [~rubenvanvreeland] Definitely! > RMQSource does not support

[jira] [Commented] (FLINK-6885) RMQSource does not support qos, leading to oom

[ https://issues.apache.org/jira/browse/FLINK-6885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16061122#comment-16061122 ] Ruben van Vreeland commented on FLINK-6885: --- Can I propose a change in a PR? > RMQSource

[GitHub] flink pull request #4161: Hot fix a description of over Table API document.

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4161#discussion_r123776397 --- Diff: docs/dev/table/tableApi.md --- @@ -1338,7 +1338,10 @@ The `OverWindow` defines a range of rows over which aggregates are computed. `Ov

[jira] [Commented] (FLINK-6964) Fix recovery for incremental checkpoints in StandaloneCompletedCheckpointStore

[ https://issues.apache.org/jira/browse/FLINK-6964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16061092#comment-16061092 ] Cliff Resnick commented on FLINK-6964: -- I'll merge and rerun. This is what I have for log scope.

[jira] [Comment Edited] (FLINK-6996) FlinkKafkaProducer010 doesn't guarantee at-least-once semantic

[ https://issues.apache.org/jira/browse/FLINK-6996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16061091#comment-16061091 ] Tzu-Li (Gordon) Tai edited comment on FLINK-6996 at 6/23/17 3:12 PM: -

[jira] [Commented] (FLINK-6996) FlinkKafkaProducer010 doesn't guarantee at-least-once semantic

[ https://issues.apache.org/jira/browse/FLINK-6996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16061091#comment-16061091 ] Tzu-Li (Gordon) Tai commented on FLINK-6996: I think its the other way around. In approach

[jira] [Commented] (FLINK-6964) Fix recovery for incremental checkpoints in StandaloneCompletedCheckpointStore

[ https://issues.apache.org/jira/browse/FLINK-6964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16061088#comment-16061088 ] Cliff Resnick commented on FLINK-6964: -- [~srichter] By hanging I mean that the checkpoint, though

[jira] [Commented] (FLINK-6097) Guaranteed the order of the extracted field references

[ https://issues.apache.org/jira/browse/FLINK-6097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16061085#comment-16061085 ] ASF GitHub Bot commented on FLINK-6097: --- Github user sunjincheng121 closed the pull request at:

[jira] [Created] (FLINK-6996) FlinkKafkaProducer010 doesn't guarantee at-least-once semantic

Piotr Nowojski created FLINK-6996: - Summary: FlinkKafkaProducer010 doesn't guarantee at-least-once semantic Key: FLINK-6996 URL: https://issues.apache.org/jira/browse/FLINK-6996 Project: Flink

[GitHub] flink pull request #3560: [FLINK-6097][table] Guaranteed the order of the ex...

Github user sunjincheng121 closed the pull request at: https://github.com/apache/flink/pull/3560 --- 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

[jira] [Commented] (FLINK-6964) Fix recovery for incremental checkpoints in StandaloneCompletedCheckpointStore

[ https://issues.apache.org/jira/browse/FLINK-6964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16061078#comment-16061078 ] Stefan Richter commented on FLINK-6964: --- Besides potential exceptions, the same logging information

[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=16061028#comment-16061028 ] 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=16061029#comment-16061029 ] 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=16061033#comment-16061033 ] 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=16061015#comment-16061015 ] 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=16061012#comment-16061012 ] 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=16061024#comment-16061024 ] 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=16061017#comment-16061017 ] 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=16061026#comment-16061026 ] 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=16061020#comment-16061020 ] 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=16061031#comment-16061031 ] 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=16061034#comment-16061034 ] 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=16060992#comment-16060992 ] 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=16061003#comment-16061003 ] 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=16061001#comment-16061001 ] 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=16061007#comment-16061007 ] 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=16061032#comment-16061032 ] 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=16061030#comment-16061030 ] 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=16060997#comment-16060997 ] 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=16060998#comment-16060998 ] 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=16060989#comment-16060989 ] 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=16061002#comment-16061002 ] 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=16061027#comment-16061027 ] 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=16061021#comment-16061021 ] 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=16061011#comment-16061011 ] 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=16061025#comment-16061025 ] 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=16060993#comment-16060993 ] 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=16061000#comment-16061000 ] 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=16061022#comment-16061022 ] 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=16061019#comment-16061019 ] 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=16060999#comment-16060999 ] 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=16061018#comment-16061018 ] 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=16060994#comment-16060994 ] 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=16061013#comment-16061013 ] 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=16061014#comment-16061014 ] 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=16060995#comment-16060995 ] 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=16061023#comment-16061023 ] 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=16060991#comment-16060991 ] 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=16061009#comment-16061009 ] 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=16061006#comment-16061006 ] 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=16061008#comment-16061008 ] 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=16061016#comment-16061016 ] 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=16061010#comment-16061010 ] 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=16060990#comment-16060990 ] 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=16061005#comment-16061005 ] 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=16060996#comment-16060996 ] 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=16061004#comment-16061004 ] 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_r123755789 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/RowTimeSortProcessFunction.scala --- @@ -0,0 +1,146 @@

[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_r123742381 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/SortUtil.scala --- @@ -0,0 +1,247 @@ +/* + * 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=16060988#comment-16060988 ] 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_r123745861 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/SortUtil.scala --- @@ -0,0 +1,247 @@ +/* + * 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_r123713426 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/CommonSort.scala --- @@ -0,0 +1,91 @@ +/* + * Licensed to

[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_r123745122 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/SortUtil.scala --- @@ -0,0 +1,247 @@ +/* + * 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_r123749098 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/SortUtil.scala --- @@ -0,0 +1,247 @@ +/* + * 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_r123752704 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeSortProcessFunction.scala --- @@ -0,0 +1,120 @@

[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_r123745157 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/SortUtil.scala --- @@ -0,0 +1,247 @@ +/* + * Licensed

  1   2   3   >