[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

2018-05-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472768#comment-16472768 ] ASF GitHub Bot commented on FLINK-9138: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

2018-05-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472559#comment-16472559 ] ASF GitHub Bot commented on FLINK-9138: --- Github user fhueske commented on the issue:

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

2018-05-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471766#comment-16471766 ] ASF GitHub Bot commented on FLINK-9138: --- Github user fhueske commented on the issue:

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

2018-05-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470277#comment-16470277 ] ASF GitHub Bot commented on FLINK-9138: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

2018-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16469170#comment-16469170 ] ASF GitHub Bot commented on FLINK-9138: --- Github user glaksh100 commented on the issue:

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

2018-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16468807#comment-16468807 ] ASF GitHub Bot commented on FLINK-9138: --- Github user StephanEwen commented on the issue:

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

2018-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16468756#comment-16468756 ] ASF GitHub Bot commented on FLINK-9138: --- GitHub user zentol opened a pull request:

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

2018-05-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465949#comment-16465949 ] ASF GitHub Bot commented on FLINK-9138: --- Github user fhueske commented on the issue:

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

2018-05-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16464434#comment-16464434 ] ASF GitHub Bot commented on FLINK-9138: --- Github user glaksh100 commented on the issue:

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

2018-05-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16464404#comment-16464404 ] ASF GitHub Bot commented on FLINK-9138: --- Github user glaksh100 commented on a diff in the pull

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

2018-05-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16464403#comment-16464403 ] ASF GitHub Bot commented on FLINK-9138: --- Github user glaksh100 commented on a diff in the pull

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

2018-05-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16462133#comment-16462133 ] ASF GitHub Bot commented on FLINK-9138: --- Github user aljoscha commented on a diff in the pull

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

2018-05-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16462128#comment-16462128 ] ASF GitHub Bot commented on FLINK-9138: --- Github user kl0u commented on a diff in the pull request:

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

2018-05-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16462122#comment-16462122 ] ASF GitHub Bot commented on FLINK-9138: --- Github user fhueske commented on the issue:

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

2018-05-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16461726#comment-16461726 ] ASF GitHub Bot commented on FLINK-9138: --- Github user glaksh100 commented on the issue:

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

2018-04-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16455598#comment-16455598 ] ASF GitHub Bot commented on FLINK-9138: --- Github user narayaruna commented on the issue:

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

2018-04-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16452451#comment-16452451 ] ASF GitHub Bot commented on FLINK-9138: --- Github user glaksh100 commented on the issue:

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

2018-04-24 Thread Narayanan Arunachalam (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16450075#comment-16450075 ] Narayanan Arunachalam commented on FLINK-9138: -- I will try the changes. Upgrading is going to

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

2018-04-24 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16450003#comment-16450003 ] Fabian Hueske commented on FLINK-9138: -- [~narayaruna], we'd probably add this feature for 1.6.0 as we

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

2018-04-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16449984#comment-16449984 ] ASF GitHub Bot commented on FLINK-9138: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

2018-04-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16449986#comment-16449986 ] ASF GitHub Bot commented on FLINK-9138: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

2018-04-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16449985#comment-16449985 ] ASF GitHub Bot commented on FLINK-9138: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

2018-04-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16449987#comment-16449987 ] ASF GitHub Bot commented on FLINK-9138: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

2018-04-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16449990#comment-16449990 ] ASF GitHub Bot commented on FLINK-9138: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

2018-04-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16449989#comment-16449989 ] ASF GitHub Bot commented on FLINK-9138: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

2018-04-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16449988#comment-16449988 ] ASF GitHub Bot commented on FLINK-9138: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

2018-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16441716#comment-16441716 ] ASF GitHub Bot commented on FLINK-9138: --- Github user glaksh100 commented on the issue:

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

2018-04-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16440162#comment-16440162 ] ASF GitHub Bot commented on FLINK-9138: --- GitHub user glaksh100 opened a pull request:

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

2018-04-05 Thread Narayanan Arunachalam (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16427293#comment-16427293 ] Narayanan Arunachalam commented on FLINK-9138: -- [~glaksh100] are you considering the PR for

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

2018-04-05 Thread Lakshmi Rao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16427291#comment-16427291 ] Lakshmi Rao commented on FLINK-9138: Agreed that event time is not applicable here. Yes, that's right,

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

2018-04-05 Thread Narayanan Arunachalam (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16427287#comment-16427287 ] Narayanan Arunachalam commented on FLINK-9138: -- This looks good. I suppose the event time is

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

2018-04-05 Thread Lakshmi Rao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16427254#comment-16427254 ] Lakshmi Rao commented on FLINK-9138: [~narayaruna]  [~fhueske] do you have thoughts on how to

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

2018-04-05 Thread Narayanan Arunachalam (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16427227#comment-16427227 ] Narayanan Arunachalam commented on FLINK-9138: -- Thanks [~glaksh100] > Enhance BucketingSink

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

2018-04-05 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16427224#comment-16427224 ] Fabian Hueske commented on FLINK-9138: -- Thank you [~glaksh100]! > Enhance BucketingSink to also

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

2018-04-05 Thread Lakshmi Rao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16427220#comment-16427220 ] Lakshmi Rao commented on FLINK-9138: Hi [~fhueske], I've marked FLINK-9118 as resolved (and duplicated

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

2018-04-05 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16427208#comment-16427208 ] Fabian Hueske commented on FLINK-9138: -- Hi [~narayaruna] and [~glaksh100], can you check if you are

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

2018-04-05 Thread Lakshmi Rao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16427186#comment-16427186 ] Lakshmi Rao commented on FLINK-9138: I had a similar request here: