Re: New Flink Runtime Monitor Dashboard

2015-07-24 Thread Stephan Ewen
Yeah, the is an "uber" JavaScript file part of the code. That accounts for a lot. We should exclude that from the stats... Am 24.07.2015 17:49 schrieb "Sachin Goel" : > According to GitHub, 26.1% code is now in JavaScript. :| > > -- Sachin Goel > Computer Science, IIT Delhi > m. +91-9871457685 > >

A soft reminder

2015-07-24 Thread Andra Lungu
Hi guys, I opened these JIRAs a while ago and, unfortunately, no one had time to look at them :|. [1] https://issues.apache.org/jira/browse/FLINK-2361 [2] https://issues.apache.org/jira/browse/FLINK-2360 [1] could probably be hacked, but [2] is a huge problem that was encountered by other people

Re: Extending the streaming scala api with stateful functions

2015-07-24 Thread Till Rohrmann
We have something similar for broadcast variables in FlinkML. It allows you to write ds.mapWithBcVariable(bcDS){ (dsElement, bcVar) => ... }. I like the idea to make the life of a Scala programmer a little bit less javaesque :-) ​ On Fri, Jul 24, 2015 at 5:45 PM, Stephan Ewen wrote: > This is r

Re: New Flink Runtime Monitor Dashboard

2015-07-24 Thread Sachin Goel
According to GitHub, 26.1% code is now in JavaScript. :| -- Sachin Goel Computer Science, IIT Delhi m. +91-9871457685 On Thu, Jul 23, 2015 at 3:12 AM, Matthias J. Sax < mj...@informatik.hu-berlin.de> wrote: > Haha! > > On 07/22/2015 07:02 PM, Kostas Tzoumas wrote: > > Finally, Flink is a JavaScr

Re: Extending the streaming scala api with stateful functions

2015-07-24 Thread Stephan Ewen
This is really syntactic sugar in the Scala API, rather then a system feature. Which is good, it needs no extra runtime constructs... On Fri, Jul 24, 2015 at 5:43 PM, Aljoscha Krettek wrote: > Yes, this might be nice. Till and I had similar ideas about using the > pattern to make broadcast vari

Re: Extending the streaming scala api with stateful functions

2015-07-24 Thread Aljoscha Krettek
Yes, this might be nice. Till and I had similar ideas about using the pattern to make broadcast variables more useable in Scala, in fact. :D On Fri, 24 Jul 2015 at 17:39 Gyula Fóra wrote: > Hey, > > I would like to propose a way to extend the standard Streaming Scala API > methods (map, flatmap,

Extending the streaming scala api with stateful functions

2015-07-24 Thread Gyula Fóra
Hey, I would like to propose a way to extend the standard Streaming Scala API methods (map, flatmap, filter etc) with versions that take stateful functions as lambdas. I think this would eliminate the awkwardness of implementing RichFunctions in Scala and make statefulness more explicit: *For exa

Re: Flink contributor list

2015-07-24 Thread Mingliang Qi
Hey Kostas, My name should be Mingliang Qi. On 24 Jul 2015, at 11:34, Kostas Tzoumas wrote: > Hi everyone, > > I compiled an up-to-date list with everyone that has contributed code to > the Flink git repository. I used git log to get unique IDs, de-duplicated > manually, and used JIRA and git

Re: Flink contributor list

2015-07-24 Thread Chesnay Schepler
Shiren is most likely me, caused by not properly configuring git. On 24.07.2015 11:34, Kostas Tzoumas wrote: Hi everyone, I compiled an up-to-date list with everyone that has contributed code to the Flink git repository. I used git log to get unique IDs, de-duplicated manually, and used JIRA an

Re: Flink contributor list

2015-07-24 Thread Ufuk Celebi
Hey Kostas, thanks for doing this. :) Great list! I would put it on the Wiki and link it from the Team page on the website. In addition, I would update the How to Release Wiki and add this as a good practice. – Ufuk On 24 Jul 2015, at 11:34, Kostas Tzoumas wrote: > Hi everyone, > > I compil

Flink contributor list

2015-07-24 Thread Kostas Tzoumas
Hi everyone, I compiled an up-to-date list with everyone that has contributed code to the Flink git repository. I used git log to get unique IDs, de-duplicated manually, and used JIRA and github to try to find the real people behind git usernames. The list is at the end of this email. It contains

[jira] [Created] (FLINK-2404) LongCounters should have an "addValue()" method for primitive longs

2015-07-24 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2404: --- Summary: LongCounters should have an "addValue()" method for primitive longs Key: FLINK-2404 URL: https://issues.apache.org/jira/browse/FLINK-2404 Project: Flink