[jira] [Commented] (FLINK-2714) Port the Flink DataSet Triangle Count example to the Gelly library

2015-10-03 Thread Saumitra Shahapure (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14942218#comment-14942218 ] Saumitra Shahapure commented on FLINK-2714: --- May I work on this issue? > Port the Flink DataSet

[jira] [Assigned] (FLINK-2730) Add CPU/Network utilization graphs to new web dashboard

2015-10-03 Thread Sachin Goel (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sachin Goel reassigned FLINK-2730: -- Assignee: Sachin Goel > Add CPU/Network utilization graphs to new web dashboard >

[GitHub] flink pull request: [FLINK-2283] [streaming] Make grouped reduce/f...

2015-10-03 Thread mbalassi
Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/1155#issuecomment-145230558 Quick update: I made some progress on the custom state checkpointer solution, but run into an issue with key selectors. This would break the current API usage of

[jira] [Commented] (FLINK-2283) Make grouped reduce/fold/aggregations stateful using Partitioned state

2015-10-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14942206#comment-14942206 ] ASF GitHub Bot commented on FLINK-2283: --- Github user mbalassi commented on the pull request:

[GitHub] flink pull request: [FLINK-2743] Add XORShfitRandom and use it in ...

2015-10-03 Thread ChengXiangLi
Github user ChengXiangLi commented on the pull request: https://github.com/apache/flink/pull/1170#issuecomment-145249544 Yes, it should be, @StephanEwen , I'm on National Day vocation now, i would update it when i come back to work at Oct 08. --- If your project is set up for it,

[jira] [Commented] (FLINK-2714) Port the Flink DataSet Triangle Count example to the Gelly library

2015-10-03 Thread Andra Lungu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14942292#comment-14942292 ] Andra Lungu commented on FLINK-2714: Sure, it's all yours! > Port the Flink DataSet Triangle Count

[jira] [Commented] (FLINK-2743) Add new RNG based on XORShift algorithm

2015-10-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14942291#comment-14942291 ] ASF GitHub Bot commented on FLINK-2743: --- Github user ChengXiangLi commented on the pull request:

[jira] [Commented] (FLINK-2811) Add page with configuration overview

2015-10-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14942230#comment-14942230 ] ASF GitHub Bot commented on FLINK-2811: --- GitHub user sachingoel0101 opened a pull request:

[GitHub] flink pull request: [FLINK-2811][web-dashboard]Add page with Confi...

2015-10-03 Thread sachingoel0101
GitHub user sachingoel0101 opened a pull request: https://github.com/apache/flink/pull/1219 [FLINK-2811][web-dashboard]Add page with Configuration Overview. Here's a screenshot: ![Configuration

[GitHub] flink pull request: Stream API Refactoring

2015-10-03 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1215#issuecomment-145254403 I updates this to also add Javadocs for the new windowing semantics/internals. --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Assigned] (FLINK-2237) Add hash-based Aggregation

2015-10-03 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay reassigned FLINK-2237: -- Assignee: Gabor Gevay > Add hash-based Aggregation > -- > >

[jira] [Assigned] (FLINK-2812) KeySelectorUtil.getSelectorForKeys and TypeExtractor.getKeySelectorTypes are incompatible

2015-10-03 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-2812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-2812: - Assignee: Márton Balassi > KeySelectorUtil.getSelectorForKeys and

[jira] [Commented] (FLINK-2807) Add javadocs/comments to new windowing mechanics

2015-10-03 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14942422#comment-14942422 ] Aljoscha Krettek commented on FLINK-2807: - I've added this to my PR:

[jira] [Updated] (FLINK-2802) Watermark triggered operators cannot progress with cyclic flows

2015-10-03 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-2802: Assignee: Gyula Fora > Watermark triggered operators cannot progress with cyclic flows >

[jira] [Updated] (FLINK-2812) KeySelectorUtil.getSelectorForKeys and TypeExtractor.getKeySelectorTypes are incompatible

2015-10-03 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-2812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-2812: -- Component/s: Streaming > KeySelectorUtil.getSelectorForKeys and

[jira] [Commented] (FLINK-2802) Watermark triggered operators cannot progress with cyclic flows

2015-10-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14942431#comment-14942431 ] ASF GitHub Bot commented on FLINK-2802: --- Github user aljoscha commented on the pull request:

[GitHub] flink pull request: [FLINK-2802] [streaming] Remove cyclic waterma...

2015-10-03 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1216#issuecomment-145281934 Yes, this is a good workaround for the time being. I think to get event time (watermarks) and cycles to work together would require something akin to the

[GitHub] flink pull request: Flink 1745

2015-10-03 Thread danielblazevski
GitHub user danielblazevski opened a pull request: https://github.com/apache/flink/pull/1220 Flink 1745 I added a quadtree data structure for the knn algorithm. @chiwanpark made originally made a pull request for a kNN algorithm, and we coordinated so that I incorporate a tree

[jira] [Commented] (FLINK-1745) Add exact k-nearest-neighbours algorithm to machine learning library

2015-10-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14942416#comment-14942416 ] ASF GitHub Bot commented on FLINK-1745: --- GitHub user danielblazevski opened a pull request:

[jira] [Commented] (FLINK-2100) Add ITCases for all Table API examples

2015-10-03 Thread rerngvit yanggratoke (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14942485#comment-14942485 ] rerngvit yanggratoke commented on FLINK-2100: - [~twalthr] I am seeing ITCases for at least the

[GitHub] flink pull request: [FLINK-2741] - Use single log statement in Tes...

2015-10-03 Thread rerngvit
GitHub user rerngvit opened a pull request: https://github.com/apache/flink/pull/1221 [FLINK-2741] - Use single log statement in TestLogger [FLINK-2741] - Use single log statement in TestLogger You can merge this pull request into a Git repository by running: $ git pull

[jira] [Commented] (FLINK-2741) Use single log statement in TestLogger

2015-10-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14942494#comment-14942494 ] ASF GitHub Bot commented on FLINK-2741: --- GitHub user rerngvit opened a pull request:

[jira] [Commented] (FLINK-2741) Use single log statement in TestLogger

2015-10-03 Thread rerngvit yanggratoke (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14942495#comment-14942495 ] rerngvit yanggratoke commented on FLINK-2741: - [~till.rohrmann] I have a PR for this issue.

[jira] [Commented] (FLINK-1940) StockPrice example cannot be visualized

2015-10-03 Thread rerngvit yanggratoke (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14942488#comment-14942488 ] rerngvit yanggratoke commented on FLINK-1940: - Should this be closed then? > StockPrice

[GitHub] flink pull request: Flink 1745

2015-10-03 Thread danielblazevski
Github user danielblazevski commented on the pull request: https://github.com/apache/flink/pull/1220#issuecomment-145293328 The Travis CI build failed. Not sure what went wrong here. How I worked with Flink was I cloned a fork, built using Maven, then imported to IntelliJ using the

[GitHub] flink pull request: Flink 1745

2015-10-03 Thread danielblazevski
Github user danielblazevski commented on the pull request: https://github.com/apache/flink/pull/1220#issuecomment-145295999 When looking at the details of the Travis CI build, I found the first error messages to be:

[jira] [Assigned] (FLINK-2741) Use single log statement in TestLogger

2015-10-03 Thread rerngvit yanggratoke (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] rerngvit yanggratoke reassigned FLINK-2741: --- Assignee: rerngvit yanggratoke > Use single log statement in TestLogger >

[jira] [Commented] (FLINK-2741) Use single log statement in TestLogger

2015-10-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14942546#comment-14942546 ] ASF GitHub Bot commented on FLINK-2741: --- Github user hsaputra commented on the pull request:

[GitHub] flink pull request: [FLINK-2741] - Use single log statement in Tes...

2015-10-03 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/1221#issuecomment-145315514 Unfortunately looks like this patch does not take advantage of slf4j parameterized logging [1]. Either do like:

[jira] [Created] (FLINK-2817) FileMonitoring function throws NPE when location is empty

2015-10-03 Thread JIRA
Márton Balassi created FLINK-2817: - Summary: FileMonitoring function throws NPE when location is empty Key: FLINK-2817 URL: https://issues.apache.org/jira/browse/FLINK-2817 Project: Flink

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

2015-10-03 Thread Suminda Dharmasena (JIRA)
Suminda Dharmasena created FLINK-2816: - Summary: Memory allocation module as a separate maven artifact Key: FLINK-2816 URL: https://issues.apache.org/jira/browse/FLINK-2816 Project: Flink

[jira] [Comment Edited] (FLINK-2066) Make delay between execution retries configurable

2015-10-03 Thread Chengxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14942140#comment-14942140 ] Chengxuan Wang edited comment on FLINK-2066 at 10/3/15 6:32 AM: Hi,

[jira] [Commented] (FLINK-2066) Make delay between execution retries configurable

2015-10-03 Thread Chengxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14942140#comment-14942140 ] Chengxuan Wang commented on FLINK-2066: --- Hi, Ewen, so the delay also should be specified as strings