Return-Path: X-Original-To: apmail-flink-dev-archive@www.apache.org Delivered-To: apmail-flink-dev-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 8A77518CE5 for ; Mon, 11 Jan 2016 13:06:03 +0000 (UTC) Received: (qmail 17318 invoked by uid 500); 11 Jan 2016 13:06:03 -0000 Delivered-To: apmail-flink-dev-archive@flink.apache.org Received: (qmail 17250 invoked by uid 500); 11 Jan 2016 13:06:03 -0000 Mailing-List: contact dev-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@flink.apache.org Delivered-To: mailing list dev@flink.apache.org Received: (qmail 17238 invoked by uid 99); 11 Jan 2016 13:06:02 -0000 Received: from Unknown (HELO spamd1-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 11 Jan 2016 13:06:02 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd1-us-west.apache.org (ASF Mail Server at spamd1-us-west.apache.org) with ESMTP id 7869FC31E1 for ; Mon, 11 Jan 2016 13:06:02 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 2.981 X-Spam-Level: ** X-Spam-Status: No, score=2.981 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, HTML_MESSAGE=3, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, URIBL_BLOCKED=0.001] autolearn=disabled Authentication-Results: spamd1-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=okkam-it.20150623.gappssmtp.com Received: from mx1-us-east.apache.org ([10.40.0.8]) by localhost (spamd1-us-west.apache.org [10.40.0.7]) (amavisd-new, port 10024) with ESMTP id 93mo2I-xAqNy for ; Mon, 11 Jan 2016 13:05:52 +0000 (UTC) Received: from mail-wm0-f51.google.com (mail-wm0-f51.google.com [74.125.82.51]) by mx1-us-east.apache.org (ASF Mail Server at mx1-us-east.apache.org) with ESMTPS id C2B1743C57 for ; Mon, 11 Jan 2016 13:05:51 +0000 (UTC) Received: by mail-wm0-f51.google.com with SMTP id f206so212003746wmf.0 for ; Mon, 11 Jan 2016 05:05:51 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=okkam-it.20150623.gappssmtp.com; s=20150623; h=mime-version:in-reply-to:references:from:date:message-id:subject:to :content-type; bh=un12UzirZ6tK/jo2OcYex2bWGrZ4BJenETvGZZhzeRs=; b=zrIuuJq+iJMaRgRh61swsrMIyszEvxO3LpmbPQ7/b6X1VCt6Ixqudb/jzLIxCa4/zx 0R3ZcpabY30+PrZmxg2zRXlobf+qm/XyGjKyYvb9ZS4EWlfkqESsweV/pQdWnbhdREnt +9h2v2Rmx2Cj8IV5ufjRLFy5S2EV8jhM1k+1/r96w6wQKckpf/5Cz0Irq3hWwBTiwEwN PAyHYkuaCkNkcFaJX/0ZQmxEN9Bb/85MN6qKkmA/f/eHLYXO3SxMAVuTUHFIIXE3VLCk 5ejOhrZFC00vILEvZjCNoV5SlUESGXseO12lk2ojcwV/Hcv6PYDOabEE5scgDHsHbw/m w3Bw== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20130820; h=x-gm-message-state:mime-version:in-reply-to:references:from:date :message-id:subject:to:content-type; bh=un12UzirZ6tK/jo2OcYex2bWGrZ4BJenETvGZZhzeRs=; b=JB7OyF5PVI3O8MUsKXPULWpSTmxRVTvID/zVaYgAp3eP0MxxI97xrwyTDz8hXCOc2t JVrQuNPMIcioOtZ7yc+qPa5tapzmjDg0s0PPPKBY2iJBwhxGMxybCd+zbivrXfS4E24W 0BxWzuqOYpIvYKjd6B4P/pXXUsuUYMpEPWIPlAM4HY6y7lvNZbxzftzEDLs7hzX7tAqB 1zLbX75TON7M8DT98BjiNyobqyhtjhvlImoQn9j0JNjhCtDB08kYqtOJ3mAGLkL2e9Kf +wk9/1fXMMsDwz1IYn8LuuxfKNNXLBIvtE8zu6OnoI7xYjiCZOj4Jgfp05Va+mYdoZ35 GSuQ== X-Gm-Message-State: ALoCoQnHklcKWnurJNNhjFU9zPRlaKdf018E4GV3gi+0smuqHMnoACdrTc9+ITw3O6EnB0LsVG9O5b2ydqScAvIulIhn8ukRtA== X-Received: by 10.28.173.71 with SMTP id w68mr14423392wme.88.1452517550864; Mon, 11 Jan 2016 05:05:50 -0800 (PST) MIME-Version: 1.0 Received: by 10.28.148.215 with HTTP; Mon, 11 Jan 2016 05:05:31 -0800 (PST) X-Originating-IP: [213.203.177.29] In-Reply-To: References: <560DB0E8.4020602@apache.org> <560E440F.6080307@apache.org> <560E4C9D.2070408@apache.org> <560ec5c5.e127b40a.d1d8e.0bc0@mx.google.com> From: Flavio Pompermaier Date: Mon, 11 Jan 2016 14:05:31 +0100 Message-ID: Subject: Re: Pulling Streaming out of staging and project restructure To: dev@flink.apache.org Content-Type: multipart/alternative; boundary=001a11444b90a64fbb05290e9890 --001a11444b90a64fbb05290e9890 Content-Type: text/plain; charset=UTF-8 Yes I know that right nowthat's to way to compile Flink without tests but from my perspective (as a developer) that's a workaround. If I don't want to compile the test classes I should be able to skip it (also because in Flink compiling tests take quite a lot). Of course it's not a big deal, it's just a matter of following Maven principle of convention-over-configuration, so test sources should go in test folders/jars. On Mon, Jan 11, 2016 at 1:54 PM, Stephan Ewen wrote: > Hi Flavio! > > You can always do "mvn -DskipTests clean package". That compiles tests, but > does not execute them. > > Stephan > > > On Mon, Jan 11, 2016 at 11:34 AM, Flavio Pompermaier > > wrote: > > > I hope that it's not too late to suggest to add to restructuring also > > https://issues.apache.org/jira/browse/FLINK-1827 so that to be able to > > compile Flink without compiling also tests (-Dmaven.test.skip=true) and > > save a lot of time... > > I should be fairly easy to fix that. > > > > Best, > > Flavio > > > > On Wed, Jan 6, 2016 at 4:22 PM, Fabian Hueske wrote: > > > > > Stephan already opened a PR for restructuring the examples: > > > > > > --> https://github.com/apache/flink/pull/1482 > > > > > > Otherwise +1! > > > > > > 2016-01-06 16:21 GMT+01:00 Robert Metzger : > > > > > > > The renaming hasn't been done completely. I would like to fix this > > before > > > > the 1.0.0 release. > > > > > > > > I think the following issues are still open: > > > > - Merge flink-java-examples, flink-scala-examples and > > > > flink-streaming-examples into "flink-examples" + build the streaming > > > > examples for the binary build as well. > > > > - move flink-table to flink-libraries > > > > - move some modules from flink-staging to flink-batch-connectors > > > > > > > > > > > > If nobody disagrees, I'll open a PR for these changes. > > > > I created a JIRA for this discussion: > > > > https://issues.apache.org/jira/browse/FLINK-3205 > > > > > > > > > > > > On Fri, Oct 2, 2015 at 7:58 PM, fhueske wrote: > > > > > > > > > +1 > > > > > > > > > > > > > > > From: Henry Saputra > > > > > Sent: Friday, October 2, 2015 19:34 > > > > > To: dev@flink.apache.org > > > > > Subject: Re: Pulling Streaming out of staging and project > restructure > > > > > > > > > > > > > > > +1 > > > > > > > > > > On Friday, October 2, 2015, Matthias J. Sax > > wrote: > > > > > > > > > > > It think, rename "flink-storm-compatibility-core" to just > > > "flink-storm" > > > > > > would be the cleanest solution. > > > > > > > > > > > > So in flink-contrib there would be two modules: > > > > > > - flink-storm > > > > > > - flink-storm-examples > > > > > > > > > > > > Please let me know if you have any objection about it. > > > > > > > > > > > > -Matthias > > > > > > > > > > > > On 10/02/2015 10:45 AM, Matthias J. Sax wrote: > > > > > > > Sure. Will do that. > > > > > > > > > > > > > > -Matthias > > > > > > > > > > > > > > On 10/02/2015 10:35 AM, Stephan Ewen wrote: > > > > > > >> @Matthias: How about getting rid of the > > storm-compatibility-parent > > > > and > > > > > > >> making the core and examples projects directly projects in > > > "contrib" > > > > > > >> > > > > > > >> On Fri, Oct 2, 2015 at 10:34 AM, Till Rohrmann < > > > > trohrmann@apache.org > > > > > > > wrote: > > > > > > >> > > > > > > >>> +1 for the new project structure. Getting rid of our code > dump > > > is a > > > > > > good > > > > > > >>> thing. > > > > > > >>> > > > > > > >>> On Fri, Oct 2, 2015 at 10:25 AM, Maximilian Michels < > > > > mxm@apache.org > > > > > > > > > > > > > >>> wrote: > > > > > > >>> > > > > > > >>>> +1 Matthias, let's limit the overhead this has for the > module > > > > > > >>> maintainers. > > > > > > >>>> > > > > > > >>>> On Fri, Oct 2, 2015 at 12:17 AM, Matthias J. Sax < > > > > mjsax@apache.org > > > > > > > > > > > > > >>> wrote: > > > > > > >>>>> I will commit something to flink-storm-compatibility > tomorrow > > > > that > > > > > > >>>>> contains some internal package restructuring. I think, > > renaming > > > > the > > > > > > >>>>> three modules in this commit would be a smart move as both > > > > changes > > > > > > >>>>> result in merge conflicts when rebasing open PRs. Thus we > can > > > > limit > > > > > > >>> this > > > > > > >>>>> pain to a single time. If no objections, I will commit > those > > > > > changes > > > > > > >>>>> tomorrow. > > > > > > >>>>> > > > > > > >>>>> -Matthias > > > > > > >>>>> > > > > > > >>>>> On 10/01/2015 09:52 PM, Henry Saputra wrote: > > > > > > >>>>>> +1 > > > > > > >>>>>> > > > > > > >>>>>> I like the idea moving "staging" projects into appropriate > > > > > modules. > > > > > > >>>>>> > > > > > > >>>>>> While we are at it, I would like to propose changing " > > > > > > >>>>>> flink-hadoop-compatibility" to "flink-hadoop". It is in my > > > > bucket > > > > > > list > > > > > > >>>>>> but would be nice if it is part of re-org. > > > > > > >>>>>> Supporting Hadoop in the connector implicitly means > > > > compatibility > > > > > > with > > > > > > >>>> Hadoop. > > > > > > >>>>>> Also same thing with "flink-storm-compatibility" to > > > > "flink-storm". > > > > > > >>>>>> > > > > > > >>>>>> - Henry > > > > > > >>>>>> > > > > > > >>>>>> On Thu, Oct 1, 2015 at 3:25 AM, Stephan Ewen < > > > sewen@apache.org > > > > > > > > > > > > > >>> wrote: > > > > > > >>>>>>> Hi all! > > > > > > >>>>>>> > > > > > > >>>>>>> We are making good headway with reworking the last parts > of > > > the > > > > > > >>> Window > > > > > > >>>> API. > > > > > > >>>>>>> After that, the streaming API should be good to be pulled > > out > > > > of > > > > > > >>>> staging. > > > > > > >>>>>>> > > > > > > >>>>>>> Since we are reorganizing the projects as part of that, I > > > would > > > > > > shift > > > > > > >>>> a bit > > > > > > >>>>>>> more to bring things a bit more up to date. > > > > > > >>>>>>> > > > > > > >>>>>>> In this restructure, I would like to get rid of the > > > > > "flink-staging" > > > > > > >>>>>>> project. Anyone who only uses the maven artifacts sees no > > > > > > difference > > > > > > >>>>>>> whether a project is in "staging" or not, so it does not > > help > > > > > much > > > > > > to > > > > > > >>>> have > > > > > > >>>>>>> that directory structure. > > > > > > >>>>>>> On the other hand, projects have a tendency to linger in > > > > staging > > > > > > >>>> forever > > > > > > >>>>>>> (like avro, spargel, hbase, jdbc, ...) > > > > > > >>>>>>> > > > > > > >>>>>>> The new structure could be > > > > > > >>>>>>> > > > > > > >>>>>>> flink-core > > > > > > >>>>>>> flink-java > > > > > > >>>>>>> flink-scala > > > > > > >>>>>>> flink-streaming-core > > > > > > >>>>>>> flink-streaming-scala > > > > > > >>>>>>> > > > > > > >>>>>>> flink-runtime > > > > > > >>>>>>> flink-runtime-web > > > > > > >>>>>>> flink-optimizer > > > > > > >>>>>>> flink-clients > > > > > > >>>>>>> > > > > > > >>>>>>> flink-shaded > > > > > > >>>>>>> -> flink-shaded-hadoop > > > > > > >>>>>>> -> flink-shaded-hadoop2 > > > > > > >>>>>>> -> flink-shaded-include-yarn-tests > > > > > > >>>>>>> -> flink-shaded-curator > > > > > > >>>>>>> > > > > > > >>>>>>> flink-examples > > > > > > >>>>>>> -> (have all examples, Scala and Java, Batch and > > Streaming) > > > > > > >>>>>>> > > > > > > >>>>>>> flink-batch-connectors > > > > > > >>>>>>> -> flink-avro > > > > > > >>>>>>> -> flink-jdbc > > > > > > >>>>>>> -> flink-hadoop-compatibility > > > > > > >>>>>>> -> flink-hbase > > > > > > >>>>>>> -> flink-hcatalog > > > > > > >>>>>>> > > > > > > >>>>>>> flink-streaming-connectors > > > > > > >>>>>>> -> flink-connector-twitter > > > > > > >>>>>>> -> flink-streaming-examples > > > > > > >>>>>>> -> flink-connector-flume > > > > > > >>>>>>> -> flink-connector-kafka > > > > > > >>>>>>> -> flink-connector-elasticsearch > > > > > > >>>>>>> -> flink-connector-rabbitmq > > > > > > >>>>>>> -> flink-connector-filesystem > > > > > > >>>>>>> > > > > > > >>>>>>> flink-libraries > > > > > > >>>>>>> -> flink-gelly > > > > > > >>>>>>> -> flink-gelly-scala > > > > > > >>>>>>> -> flink-ml > > > > > > >>>>>>> -> flink-table > > > > > > >>>>>>> -> flink-language-binding > > > > > > >>>>>>> -> flink-python > > > > > > >>>>>>> > > > > > > >>>>>>> > > > > > > >>>>>>> flink-scala-shell > > > > > > >>>>>>> > > > > > > >>>>>>> flink-test-utils > > > > > > >>>>>>> flink-tests > > > > > > >>>>>>> flink-fs-tests > > > > > > >>>>>>> > > > > > > >>>>>>> flink-contrib > > > > > > >>>>>>> -> flink-storm-compatibility > > > > > > >>>>>>> -> flink-storm-compatibility-examples > > > > > > >>>>>>> -> flink-streaming-utils > > > > > > >>>>>>> -> flink-tweet-inputformat > > > > > > >>>>>>> -> flink-operator-stats > > > > > > >>>>>>> -> flink-tez > > > > > > >>>>>>> > > > > > > >>>>>>> flink-quickstart > > > > > > >>>>>>> -> flink-quickstart-java > > > > > > >>>>>>> -> flink-quickstart-scala > > > > > > >>>>>>> -> flink-tez-quickstart > > > > > > >>>>>>> > > > > > > >>>>>>> flink-yarn > > > > > > >>>>>>> flink-yarn-tests > > > > > > >>>>>>> > > > > > > >>>>>>> flink-dist > > > > > > >>>>>>> > > > > > > >>>>>>> flink-benchmark > > > > > > >>>>>>> > > > > > > >>>>>>> > > > > > > >>>>>>> Let me know if that makes sense! > > > > > > >>>>>>> > > > > > > >>>>>>> Greetings, > > > > > > >>>>>>> Stephan > > > > > > >>>>> > > > > > > >>>> > > > > > > >>> > > > > > > >> > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > --001a11444b90a64fbb05290e9890--