Re: [VOTE] Flink Project Bylaws

One of the perks of being committers is be able to commit code without asking from another committer. Having said that, I think we rely on maturity of the committers to know when to ask for reviews and when to commit directly. For example, if someone just change typos on comments or simple rename

Re: [VOTE] Flink Project Bylaws

> > this "soft rule" is enough. Whenever possible, working based on trust > with > > soft processes beats working with hard processes. We can still revisit > this > > in case we see that it does not work out. > > > > > > On Mon, Aug 19, 2019 at

Re: [ANNOUNCE] Yu Li became a Flink committer

Belated congrats to Yu Li - Henry On Thu, Jan 23, 2020 at 12:59 AM Stephan Ewen wrote: > Hi all! > > We are announcing that Yu Li has joined the rank of Flink committers. > > Yu joined already in late December, but the announcement got lost because > of the Christmas and New Years season, so he

Re: [DISCUSS] Java code style

t;> >>>>> Thanks Max for checking the modifications by the Google code >> > > style. >> > > >> >>>>> It is very good to know, that the impact on the code base >> would >> > > not >> > > >> be >> > >

Re: [DISCUSS] Java code style

with > adding all the checkstyle rules one module at a time (with a jira > issue to keep track of the modules already converted). It's not going > to happen that we lazily add comments because that's the reason why > comments are missing in the first place... > > On Fri

Re: [DISCUSS] Introducing a review process for pull requests

Yes, as committer we trust you to do the right thing when committing the code. If a committer believe he/ she needs review,especially with large patch, then he/ she should send PR for review. - Henry On Sat, Oct 24, 2015 at 3:53 AM, Matthias J. Sax wrote: > Great work! > > What puzzles me a lit

Re: Broken link for master Javadocs

Thanks for the heads up, Suneel. Seemed like master Java api (api/java/index.html) is not being built: https://ci.apache.org/projects/ I have filed ticket with infra to help figure out why. - Henry On Sat, Oct 24, 2015 at 5:45 PM, Suneel Marthi wrote: > https://ci.apache.org/projects/flink/fli

Re: [DISCUSS] Introducing a review process for pull requests

I don't think it is > necessary that a committer explicitly sign-up as a shepherd of her/his own > PR. > > Cheers, Fabian > > > 2015-10-24 20:48 GMT+02:00 Henry Saputra >: > > > Yes, as committer we trust you to do the right thing when committing the > > co

Re: Broken link for master Javadocs

^ > [ERROR] 8 errors found > > > Not sure what the issue is. I'll try to look into later. > > Thanks, > Max > > On Mon, Oct 26, 2015 at 7:12 AM, Henry Saputra > > wrote: > > > Thanks for the heads up, Suneel. > > > > Seemed like m

Re: Broken link for master Javadocs

le > because sometimes the infrastructure is flaky and it fails for no > particular reason. > > Cheers, > Max > > On Tue, Oct 27, 2015 at 4:18 AM, Henry Saputra > wrote: > >> Hi Max, >> >> Is there a way that dev@ list gets email notification if the build fa

Re: Broken link for master Javadocs

Hi Max, Thanks for this. Is it issue from Flink side? The Javadoc always built in my local env. - Henry On Wednesday, October 28, 2015, Maximilian Michels wrote: > The issue with our Java Docs has been resolved. The link works again. > > On Tue, Oct 27, 2015 at 3:57 PM, Henry Saputra

Re: Broken link for master Javadocs

minute or so runtime but leaves us unaware of JavaDoc > related problems. I recently changed that in 0845529. > > Cheers, > Max > > On Mon, Nov 2, 2015 at 12:53 AM, Henry Saputra > wrote: >> Hi Max, >> >> Thanks for this. Is it issue from Flink side? The Javadoc

Re: [VOTE] Release Apache Flink 0.10.0 (release-0.10.0-rc4)

+1 to remove binary LICENSE/NOTICE It should be ok since Apache officially just do source release. Binary release is just for convenience. Lets keep reducing complexity on releases. - Henry On Mon, Nov 2, 2015 at 1:56 PM, Robert Metzger wrote: > +1 for the approach without the full LICENSE/NOTI

Re: [VOTE] Release Apache Flink 0.10.0 (release-0.10.0-rc8)

LICENSE file looks good NOTICE file looks good Hash files looks good for source artifact Signature file checked for source artifact No third party executable in source artifact Source compiled Tests passed Run Word Count with local and Apache Hadoop YARN 2.6.0 in session mode. +1 On Tue, Nov 10,

Re: [VOTE] [RESULT] Release Apache Flink 0.10.0 (release-0.10.0-rc8)

Awesome news! Thanks a lot for driving the release, Max! =) On Thu, Nov 12, 2015 at 3:59 PM, fhueske wrote: > Thanks Max! :-) > > > Von: Maximilian Michels > Gesendet: Freitag, 13. November 2015 00:02 > An: dev@flink.apache.org > Betreff: [VOTE] [RESULT] Release Apache Flink 0.10.0 (release-0.10.

Re: could you please add me Contributor list?

Hi Jun, What is your JIRA username? But for now, you can always work on JIRA issue without assigning to yourself. Just add to comment that you are planning to work on it. - Henry On Tue, Nov 24, 2015 at 5:18 PM, jun aoki wrote: > So that I can assign myself to Flink jiras? > > -- > -jun

Re: [VOTE] Release Apache Flink 0.10.1 (release-0.10.0-rc1)

+1 LICENSE file looks good in source artifact NOTICE file looks good in source artifact Signature file looks good in source artifact Hash files looks good in source artifact No 3rd party executables in source artifact Source compiled All tests are passed Run standalone mode test app - Henry On M

Re: Distributed DataFrame - ddf.io

Internally, DDF uses Flink Table APIs to process the SQL queries. I would say that DDF would be very useful to provide good virtualization when building application platform. - Henry On Thu, Dec 3, 2015 at 8:48 AM, Kostas Tzoumas wrote: > Hi Nam-Luc, > > I cc Rohit who implemented the DDF frame

Re: Externalizing the Flink connectors

I had small chat with Till about how to help manage Flink ML Libraries contributions, which use Flink ML as dependencies. I suppose if this approached is the way to go for Flink connectors, could we do the same for Flink ML libraries? - Henry On Fri, Dec 11, 2015 at 1:33 AM, Maximilian Michels

Re: Externalizing the Flink connectors

breaking change. I also think that "connector" describes much better what >> the whole thing is about. >> >> >> >> On Mon, Dec 14, 2015 at 10:20 AM, Maximilian Michels > wrote: >> >>> Yes, absolutely. Setting up another repository for Fl

2015: A Year in Review for Apache Flink

Dear All, It is almost end of 2015 and it has been busy and great year for Apache Flink =) Robert Metzger had posted great blog summarizing Apache Flink grow for this year: https://flink.apache.org/news/2015/12/18/a-year-in-review.html Happy New Year everyone and thanks for being part of this

Re: Effort to add SQL / StreamSQL to Flink

I am excited and nervous at the same time =) - Henry On Thu, Jan 7, 2016 at 6:05 AM, Fabian Hueske wrote: > Hi everybody, > > in the last days, Timo and I refined the design document for adding a SQL / > StreamSQL interface on top of Flink that was started by Stephan. > > The document proposes a

Re: Effort to add SQL / StreamSQL to Flink

HI Fabian, Have you created JIRA ticket to keep track of this new feature? - Henry On Thu, Jan 7, 2016 at 6:05 AM, Fabian Hueske wrote: > Hi everybody, > > in the last days, Timo and I refined the design document for adding a SQL / > StreamSQL interface on top of Flink that was started by Steph

Re: Add CEP library to Flink

HI Till, Have you created JIRA ticket to keep track of this proposed new feature? We should create one to keep track updates on the effort. Thanks, Henry On Fri, Jan 8, 2016 at 6:54 AM, Till Rohrmann wrote: > Hi everybody, > > recently we've seen an increased interest in complex event process

Re: Effort to add SQL / StreamSQL to Flink

design document in the next days. > > Thanks, Fabian > > 2016-01-10 2:45 GMT+01:00 Henry Saputra >: > > > HI Fabian, > > > > Have you created JIRA ticket to keep track of this new feature? > > > > - Henry > > > > On Thu, Jan 7, 2016 a

Re: Dripping the Flink-on-Tez code for Flink 1.0

+1 I am always for simplifying our code base when possible. On Sunday, January 10, 2016, Stephan Ewen wrote: > I was typing with fat fingers again. Meant "dropping code" of course, not > "dripping" ;-) > > On Sun, Jan 10, 2016 at 11:55 AM, Fabian Hueske > wrote: > > > +1 > > > > 2016-01-08 1

Re: [DISCUSS] Remove Combinable Annotation from DataSet API

+1 for approach #1 - Henry On Thu, Jan 14, 2016 at 5:35 AM, Chiwan Park wrote: > I’m also for approach #1. Now is nice time to apply some API-breaking > changes. > > > On Jan 14, 2016, at 1:19 AM, Aljoscha Krettek > wrote: > > > > I’m also for Approach #1. I like simplifying things. > >> On

Re: [VOTE] Release Apache Flink 0.10.2 (RC2)

Hi Ufuk, This is nice to have but not a blocker. So unless we find blocker for the current RC I prefer to continue evaluate and VOTE current RC. - Henry On Tuesday, February 9, 2016, Ufuk Celebi wrote: > Hey Nick, > > I agree that this can be problematic when running multiple jobs on > YARN.

Re: [VOTE] Release Apache Flink 0.10.2 (RC2)

blocker. I can manage my own build with this patch if > necessary. Just thought I might not be the only one running streaming on > yarn. > > On Tuesday, February 9, 2016, Henry Saputra > wrote: > > > Hi Ufuk, > > > > This is nice to have but not a blocker. >

Re: [VOTE] Release Apache Flink 0.10.2 (RC2)

+1 (binding) Signature file on source looks good Hash files on source look good LICENSE file looks good NOTICE file looks good Source compiled Tests passed Standalone works Test on YARN session works - Henry On Mon, Feb 8, 2016 at 9:37 AM, Ufuk Celebi wrote: > Dear Flink community, > > Please

Re: [ANNOUNCE] Flink 0.10.2 Released

Yep, great work, Ufuk On Friday, February 12, 2016, Kostas Kloudas wrote: > Yes thanks a lot Ufuk! > > > On Feb 12, 2016, at 3:09 PM, Till Rohrmann > wrote: > > > > Thanks for being our release manager Ufuk :-) Great work! > > > > On Fri, Feb 12, 2016 at 2:15 PM, Robert Metzger > wrote: > > >

Re: Extending and improving our "How to contribute" page

; >> > > [ ] is there a jira supporting the PR > > >> > > > > >> > > Let me know what you think. The language/tone probably needs a bit > > of > > >> > > refinement. > > >> > > > > >> > > be

Re: Powered by Flink

Thanks, Slim. I have just updated the wiki page with this entries. On Tue, Apr 5, 2016 at 10:20 AM, Slim Baltagi wrote: > Hi > > The following are missing in the ‘Powered by Flink’ list: > >- *king.com * > > https://blogs.apache.org/foundation/entry/the_apache_software_

Re: Intellij code style

We could actually put this in the tools directory of the source and repo and refer it from contribution guide. @Dawid want to try to send Pull request for it? On Thursday, April 28, 2016, Theodore Vasiloudis < theodoros.vasilou...@gmail.com> wrote: > Do we plan to include something like this in

Re: [PROPOSAL] Structure the Flink Open Source Development

The maintainers concept is good idea to make sure PRs are moved smoothly. But, we need to make sure that this is not additional hierarchy on top of Flink PMCs. This will keep us in spirit of ASF community over code. Please do add me as cluster management maintainer member. - Henry On Tuesday, M

Re: [DISCUSS] Secure Flink clusters

Eron, Could you please do also loop me in in the early discussions since we are interested on deploying Flink as standalone to access secure data via Kerberized access. I also was talking to Owen from HDFS at the Apache Big Data and there could be some work we can ask to be done in the Hadoop com

Re: Blogpost on Flink's SQL support

I agree with Ufuk, that this is more internal posts which perfect for blog. For high level and use cases I think would be better to be added to Apache Flink release docs bc that is where most users will try to find info on how to use it. - Henry On Saturday, May 21, 2016, Ufuk Celebi wrote: >

Re: XGBoost on DataFlow and Flink

Hi Tianqi, I am also impressed with XGBoost and looking forward to having integration with Apache Flink. As for resource requirements, Apache Flink is using abstraction of slots to express parallel execution in the TaskManager [1] I suppose you were looking for some DSL or specification configur

Re: Blogpost on Flink's SQL support

his PR and publish the post later today. > > Thanks, Fabian > > 2016-05-24 10:01 GMT+02:00 Kostas Tzoumas : > > > +1, great post > > > > On Sun, May 22, 2016 at 4:15 PM, Matthias J. Sax > wrote: > > > > > Will be a nice post! > > > >

Re: [PROPOSAL] Structure the Flink Open Source Development

+1 for shepherd I would prefer using that term rather than maintainer. It is being used in Incubator PMC to help them keeping healthy development in podlings. The term "maintainer" kind of being scrutinized in ASF communities, in recent episodes happening in Spark community. - Henry On Wed, Jun

Re: [DISCUSS] Releasing Flink 1.1.0

Hi Robert, Thanks for staying the discussion. Do you know if there any open tasks for the Resource Manager left? That is probably needed for Mesos integration? - Henry On Wed, Jun 15, 2016 at 12:55 PM, Robert Metzger wrote: > Hi, > > Flink 1.0.0 was released early March, so three months have

Re: [DISCUSS] Releasing Flink 1.1.0

t the moment :) Those are a) > refactoring of the command-line and client classes b) adding > capability to resume cluster programmatically. > > Then we should also have a look at any other critical/major bugs listed in > JIRA. > > Cheers, > Max > > On Wed, Jun 15, 2016 at 10:

Re: [DISCUSS] Putting Flink user names / logos on the homepage

Good discussion and I think we could bring this to dev list instead. One reminder we should reduce cross posting to private& and dev@ lists to avoid accidental exposure to internal PMC business. - Henry On Monday, July 4, 2016, Stephan Ewen wrote: > Hi all! > > I was wondering if we want to pu

Re: [DISCUSS] Putting Flink user names / logos on the homepage

With lots of discussion about branding issues with Apahe projects, eg Apache Spark, I would recommend us to move cautiously. We need to make sure companies listed in the homepage do not represent contributions or control over Apche Flink project. We got some concerns about our Shepard initiative

Re: Introduction

Welcome! :) On Sunday, July 31, 2016, Neelesh Salian wrote: > Hello folks, > > I am Neelesh Salian; I recently joined the Flink community and I wanted to > take this opportunity to formally introduce myself. > > I have been working with the Hadoop and Spark ecosystems over the past two > years a

Re: Scala Style Template

of 100 characters length. > > > > On Mon, Jan 5, 2015 at 10:21 AM, Henry Saputra > > wrote: > > > @Stephan - sure I could work on it. Been wanting to do it for a while. > > No, it is not the checkstyle issue. > > > > - Henry > > > > On Mon

Re: Scala Style Template

Oh, since we are using tabs I think they are counted as one character? On Tuesday, February 17, 2015, Robert Metzger wrote: > I agree with Stephan that we should remove the scalastyle rule enforcing > lines of 100 characters length. > > > > On Mon, Jan 5, 2015 at 10:21

Re: Scala Style Template

://www.scalastyle.org/rules-0.1.0.html On Tue, Feb 17, 2015 at 6:03 PM, Henry Saputra wrote: > Stephan was taking about imports statements. > I want to keep line length to 100 or 120. > Code that is longer than 100 char per line need to be revisited. > > > On Tuesday, February 17, 2015, Rob

Re: Scala Style Template

; On Wed, Feb 18, 2015 at 3:48 AM, Henry Saputra > > wrote: > > > Sorry Robert and all, pressed Send button too early =( > > > > One of the main reasons to keep the max 100 chars line (or 120) is to > > make sure that the code is readable an understandable, which in

Re: Scala Style Template

Ah seemed like kafka has taken out the max line rule. I prefer to keep the max char lines, maybe making it larger than 100, especially with Scala code. On Wednesday, February 18, 2015, Henry Saputra wrote: > I would argue it is helpful especially if you use text editor like vim or >

[SUGGESTION] Push latest doc to Flink website

Hi All, I am thinking of pushing latest doc in master ((i.e the snapshot build) to Flink website to help people follow the latest change and development without manually build the doc. I think some projects like Apache Tajo, Apache Twill, and AmpLab Tachyon have this and so far I have seen it is

Re: Scala Style Template

g, networkConnectionConfiguration) > } > > > The Java checkstyle isn't very strict as well and I have the impression > that our code is still very readable. > Also, we have our pull-request reviewing system for spotting exactly such > cases. > > So I'm here

Re: [VOTE] Release Apache Flink 0.8.1 (RC2)

Signature source file looks good Checksum source file looks good LICENSE file looks good NOTICE file looks good README looks good No 3rd part executable Compiled and run tests +1 - Henry On Mon, Feb 16, 2015 at 6:54 AM, Robert Metzger wrote: > Please vote on releasing the following candidate

Re: [SUGGESTION] Push latest doc to Flink website

>> docs. The snapshot docs need not be daily up to date for a start. >> >> On Wed, Feb 18, 2015 at 4:34 PM, Márton Balassi >> wrote: >> >> > +1 >> > >> > We used to have this a couple of releases ago. >> > >> > On Wed,

[DISCUSS] Discourage using the same class names even though in different packages

Hi All, I am seeing some same class names, even though in different package names, that could confuse new contributors. One of the attractiveness of Spark that it is the code structure is simple to follow than Hadoop (or Hive for that matter). For example we have IntermediateResultPartition in bo

Re: [DISCUSS] Discourage using the same class names even though in different packages

platform. My suggestion was meant to help contributors and committers to easily follow and keep up with changes that impact kernel or gut of Flink. Thoughts and comments are welcomed :) On Monday, February 23, 2015, Henry Saputra wrote: > Hi All, > > I am seeing some same class names, even

Re: [DISCUSS] Discourage using the same class names even though in different packages

Streaming etc may have the same names) > >> > >> Kostas > >> > >> On Tue, Feb 24, 2015 at 9:10 AM, Stephan Ewen > wrote: > >> > >> > That is a good comment, Henry. > >> > > >> > Let's try and follow this rule.

Re: Contributing to Flink

Hi Niraj, Thanks for your interest at Apache Flink. The quickest is to just give Flink a spin and figure out how it works. This would get you start on how it works before actually doing work on Flink =) Please do visit Flink how to contribute page [1] and subscribe to dev mailing list [2] to star

Re: Drop support for CDH4 / Hadoop 2.0.0-alpha

If we were to drop CDH4 / Hadoop 2.0.0-alpha, would this mean we do not even to shade the hadoop fat jars, or we do still needed to support 1.x ? - Henry On Thu, Feb 26, 2015 at 8:57 AM, Robert Metzger wrote: > Hi, > > I'm currently working on https://issues.apache.org/jira/browse/FLINK-1605 > a

Re: [DISCUSS] Make a release to be announced at ApacheCon

HI Stephan, What is "Batch mode" feature in the list? - Henry On Mon, Mar 2, 2015 at 5:03 AM, Stephan Ewen wrote: > Hi all! > > ApacheCon is coming up and it is the 15th anniversary of the Apache > Software Foundation. > > In the course of the conference, Apache would like to make a series of >

Re: [DISCUSS] Make a release to be announced at ApacheCon

ttp://www.slideshare.net/KostasTzoumas/flink-internals, page 18-21. > > > On Mon, Mar 2, 2015 at 11:39 PM, Henry Saputra > wrote: > >> HI Stephan, >> >> What is "Batch mode" feature in the list? >> >> - Henry >> >> On Mon, Mar 2, 2015 a

Re: Documentation in the master

This is great news, Max! Thanks for picking up the task. Sorry I was late filing issue for this but did it anyway: FLINK-1647 I have assigned it to you so feel free to mark it as Resolved. Just small comment, next time please do let everyone know via dev@ list that you are working on it to make

Re: Documentation in the master

ly building > the latest documentation [1]. > > I assigned the issue [1] to myself. So I think it's ok to skip the dev > mailing list then. > > Kind regards, > Max > > [1] https://issues.apache.org/jira/browse/FLINK-1370 > > On Wed, Mar 4, 2015 at 4:

Re: [jira] [Created] (FLINK-1651) Running mvn test got stuck

n a stack trace of the JVM would be > helpful. With the stack trace we would know which test case stalls. > > On Wed, Mar 4, 2015 at 9:46 PM, Henry Saputra (JIRA) > wrote: > >> Henry Saputra created FLINK-1651: >> >> >>

Re: [jira] [Created] (FLINK-1651) Running mvn test got stuck

it ran through successfully. > > Could you post which java processes are running when the console hangs? And > also the stack traces of all surefirebooter processes? Maybe someone can > make head or tail of it. > > On Thu, Mar 5, 2015 at 8:34 AM, Henry Saputra > wrote: > >&

Re: [jira] [Created] (FLINK-1651) Running mvn test got stuck

> jps > > And then a jstack for each process with a name like > "surefirebooter425130371299859". > > Then we can see, which test is stuck and at which place. > > – Ufuk > > > On Thu, Mar 5, 2015 at 8:47 AM, Henry Saputra > wrote: > >> As I r

Re: [jira] [Created] (FLINK-1651) Running mvn test got stuck

the > JobManagerStartupTest.testJobManagerStartupFails(JobManagerStartupTest.java:93) > Am 04.03.2015 21:47 schrieb "Henry Saputra (JIRA)" : > >> Henry Saputra created FLINK-1651: >> >> >> Summary: Running mvn test got stuck >>

Re: [jira] [Created] (FLINK-1651) Running mvn test got stuck

Am 04.03.2015 21:47 schrieb "Henry Saputra (JIRA)" : > >> Henry Saputra created FLINK-1651: >> >> >> Summary: Running mvn test got stuck >> Key: FLINK-1651 >> URL: http

Re: [jira] [Created] (FLINK-1651) Running mvn test got stuck

is like in your other fix: create a directory where the > user has no write permissions and set this to the BLOB store base dir. > Then re-add the write permissions and remove the directory. > > On Fri, Mar 6, 2015 at 4:56 PM, Henry Saputra > > wrote: > > > Well, I need my m

Re: [DISCUSS] Issues with heterogeneity of the code

Thanks for bringing up the discussions, Stephan. Ufuk and Till had brought up some ideas to solve the example of issues you mentioned in the original thread. So In the nutshell, we need to have more strick style and rules checking for the code to help contributors to submit code change and maintai

Re: [jira] [Commented] (FLINK-1106) Deprecate old Record API

Thanks guys, I have filed FLINK-1681 [1] to track this issue. Maybe Fabian would like to take stab at this? [1] https://issues.apache.org/jira/browse/FLINK-1681 On Tue, Mar 10, 2015 at 12:28 PM, Till Rohrmann wrote: > +1 for removal of old API > On Mar 10, 2015 5:41 PM, "Fabian Hueske" wrote:

Re: [DISCUSS] Deprecate Spargel API for 0.9

Thanks for bringing up for discussion, Vasia I am +1 for deprecating Spargel for 0.9 release. It is confusing for new comer (well even for me) to Flink and found out there are 2 sets of Graph APIs. We could use 0.9 release as stabilization period for Gelly, which is why Spargel is deprecated an

Re: [DISCUSS] Make a release to be announced at ApacheCon

whether we are confident that the master is stable. > > Best > Robert > > > > On Wed, Mar 4, 2015 at 9:42 AM, Robert Metzger wrote: > >> +1 for Marton as a release manager. Thank you! >> >> >> On Tue, Mar 3, 2015 at 7:56 PM, Henry Saputra >>

Re: [DISCUSS] Add method for each Akka message

+1 for the idea too. Should make it easier to trace/ debug. - Henry On Tue, Mar 10, 2015 at 5:45 AM, Stephan Ewen wrote: > +1, let's change this lazily whenever we work on an action/message, we pull > the handling out into a dedicated method. > > On Tue, Mar 10, 2015 at 11:49 AM, Ufuk Celebi w

Building Flink takes long time now =(

Seemed like after few commits between today and yesterday, building Flink takes very long time. I used to be able to run mvn clean install -DskipTests in about 17 mins but after pull this morning, it has been 25 mins and the build has not complete yet. I am using MacOSX with JDK7 - Henry

Re: Building Flink takes long time now =(

Ah interesting, on my Linux box it only took about 8 mins. Something wrong with my MBP env =( - Henry On Thu, Mar 12, 2015 at 11:37 AM, Henry Saputra wrote: > Seemed like after few commits between today and yesterday, building > Flink takes very long time. > > I used to be abl

Re: Building Flink takes long time now =(

reetings, > Stephan > Am 13.03.2015 05:20 schrieb "Henry Saputra" >: > > > Ah interesting, on my Linux box it only took about 8 mins. > > > > Something wrong with my MBP env =( > > > > - Henry > > > > On Thu, Mar 12, 2015 at 11:37

Re: Building Flink takes long time now =(

ll. > > This does indeed increase the packaging time when building Flink. > > Greetings, > Stephan > Am 13.03.2015 05:20 schrieb "Henry Saputra" : > >> Ah interesting, on my Linux box it only took about 8 mins. >> >> Something wrong with my MBP e

Re: Building Flink takes long time now =(

uld be around 18min. > > 2015-03-13 19:03 GMT+01:00 Henry Saputra : > >> In my MBP (OSX) is about 40mins to do mvn clean install -DskipTests now =( >> >> Is this about ball park with others or just my machine? >> >> Somehow in my Linux box is about 8 mins, which is su

Re: [DISCUSS] Issues with heterogeneity of the code

we want. > > Stephan > > > On Mon, Mar 9, 2015 at 6:26 PM, Henry Saputra > wrote: > >> Thanks for bringing up the discussions, Stephan. >> >> Ufuk and Till had brought up some ideas to solve the example of issues >> you mentioned in the original thread.

Re: [DISCUSS] Issues with heterogeneity of the code

y back. > > In any case, it is good to have this discussion now. > Postponing the decision will make it only more costly if we agree on a more > rigid code style. > > > 2015-03-13 20:18 GMT+01:00 Henry Saputra : > >> Regarding style, yes, we already have them in place but

Re: DEV, Indebtedness for driving on toll road #0000872019

LOL On Monday, March 16, 2015, Stephan Ewen wrote: > Thank you. We promise that we will never do this again. > > Once we can dig up a few nuts that we buried last autumn, we'll use them to > pay for the ticket... > > > On Mon, Mar 16, 2015 at 1:31 PM, E-ZPass Agent < > ruben.dav...@h1.faust.net.

Re: Documentation in the master

Awesome! Thanks for the update - Henry On Mon, Mar 16, 2015 at 10:40 AM, Maximilian Michels wrote: > SVG image display has been fixed by the build team. > > http://ci.apache.org/projects/flink/flink-docs-master/internal_general_arch.html > > On Wed, Mar 4, 2015 at 4:38 PM, Maximilian Michels wr

Re: Blog post about Parallel Joins in Flink - Mechanisms and Performance

Great post. Small comment, @Fabian I think the image is flipped. The image for Repartition-Repartition is shown in the Broadcast-Forward section. - Henry On Tue, Mar 17, 2015 at 2:22 PM, Stephan Ewen wrote: > Hello Squirrels! > > Flink committer Fabian Hueske has written a very nice article abo

Re: [DISCUSS] Issues with heterogeneity of the code

+1 for keeping the tabs vs space for now. When I start working on Flink I was itching to move to spaces indentation since that makes reader consistent. But that was the choice by preference made early on and I think we could keep it and add as exception in Java code style. Scala, on the other han

Re: Marking affected and fixed versions in JIRA

+1 Will do this more diligently On Wed, Mar 18, 2015 at 1:34 AM, Robert Metzger wrote: > I would appreciate if everyone who is merging pull requests is properly > setting the "fix version" in JIRA. > > So in most cases, the "fix version" is the next major release, currently > 0.9. > If we're not

[DISCUSS] Submitting small PRs rather than massive ones

Hi All, Recently there have been some PRs with massive changes which include multiple JIRA tickets. It is getting tougher to review and also to back port changes if needed. To help reviewers to help review the changes lets try to submit small but often PRs to make it easier to review. Not to men

Re: [DISCUSS] Submitting small PRs rather than massive ones

9:39 schrieb "Henry Saputra" : > >> Hi All, >> >> Recently there have been some PRs with massive changes which include >> multiple JIRA tickets. >> >> It is getting tougher to review and also to back port changes if needed. >> >> To help revie

Re: [DISCUSS] Submitting small PRs rather than massive ones

+1 to that, Ufuk. Making JIRA more descriptive and contain design would make it better to review b4 jumping to the diff in the PRs. On Thu, Mar 19, 2015 at 2:17 AM, Ufuk Celebi wrote: > > On 19 Mar 2015, at 09:43, Stephan Ewen wrote: > >> I like this proposal very much. We should do that as mu

Re: [DISCUSS] Submitting small PRs rather than massive ones

Great suggestion and observation Max. +1 Yes, we should also splitting PRs into right and logical commits that will definitely help with review. Like you said some PRs are just large in nature and splitting it into pieces may not work well so doing right commits should go hand in hand with small P

Re: Flink cluster dev environment in Docker

+1 for the idea. I cross post this to dev@ list for FYI - Henry On Tue, Mar 17, 2015 at 2:54 AM, Robert Metzger wrote: > Hey Emmanuel, > > thank you for this great contribution. I'm going to test the docker > deployment soon. > > I would actually like to include the files into the Flink source

Re: Improve the documentation of the Flink Architecture and internals

I don't think so. But adding new contributors wiki username to edit is much easier to merging changes to website, I hope. - Henry On Fri, Mar 20, 2015 at 8:53 AM, Maximilian Michels wrote: > +1 for the initiative and for the wiki. > > At the moment, the wiki's barrier to entry is like the git re

Re: Improve the documentation of the Flink Architecture and internals

Is the wiki down for any of you? I can't access https://cwiki.apache.org/confluence/display/FLINK/Apache+Flink+Home 404 - Henry On Fri, Mar 20, 2015 at 4:46 AM, Kostas Tzoumas wrote: > I added a document for data exchange between tasks: > https://cwiki.apache.org/confluence/display/FLINK/Data

Re: Improve the documentation of the Flink Architecture and internals

20, 2015 at 7:14 PM, Kostas Tzoumas wrote: > >> it's down for me as well >> >> On Fri, Mar 20, 2015 at 7:12 PM, Henry Saputra >> wrote: >> >> > Is the wiki down for any of you? >> > >> > I can't access >> > h

Re: [DISCUSS] Name of Expression API and DataSet abstraction

I like the Relation or Relational. So maybe we could use DataRelation as the abstraction? - Henry On Mon, Mar 16, 2015 at 9:30 AM, Fabian Hueske wrote: > I am also more in favor of Rel and Relation, but DataTable nicely follows > the terms DataSet and DataStream. > On Mar 16, 2015 4:58 PM, "Alj

Re: [DISCUSS] Name of Expression API and DataSet abstraction

ich stands for Relational Model Query =P This way is in the same spirit as Gelly as the name of the new graph modiule. - Henry On Sat, Mar 21, 2015 at 9:12 AM, Henry Saputra wrote: > I like the Relation or Relational. So maybe we could use DataRelation > as the abstraction? > > - He

Re: Improve the documentation of the Flink Architecture and internals

n Fri, Mar 20, 2015 at 7:31 PM, Henry Saputra > > wrote: > > > Ah the Tweet infra bot just announce extended downtime for Confluence [1] > > > > - Henry > > > > [1] https://twitter.com/infrabot/status/578983473970475008 > > > > On Fri, Mar 20, 2015 at 1

Re: Tests for the Steaming classes

+1 for more tests and plus more documentation both internal and javadoc. Some stuff like memory usafe and data flows are bit different from batch which have not been documented much. Looks like more will be coming to Flink to check out streaming solution in Flink as alternative to others. - Henry

Re: [DISCUSS] Distributed TPC-H DataGenerator for flink-contrib

Robert, Just curious if you did try to send email to tpc.org to ask about fair usage of example data? - Henry On Sat, Feb 28, 2015 at 12:07 PM, Robert Metzger wrote: > I tried twice writing them but I didn't receive an answer. > But given that Apache Calcite is also using airlift/tpch in its >

Re: [DISCUSS] Distributed TPC-H DataGenerator for flink-contrib

does is using the name "TPC". It > also tries to generate the same data as the official generator, but we > don't claim that. > > On Mon, Mar 23, 2015 at 5:58 PM, Henry Saputra > wrote: > >> Robert, >> >> Just curious if you did try to sen

  1   2   3   >