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 268C218945 for ; Tue, 12 May 2015 08:46:59 +0000 (UTC) Received: (qmail 38365 invoked by uid 500); 12 May 2015 08:46:59 -0000 Delivered-To: apmail-flink-dev-archive@flink.apache.org Received: (qmail 38310 invoked by uid 500); 12 May 2015 08:46:59 -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 38299 invoked by uid 99); 12 May 2015 08:46:59 -0000 Received: from mail-relay.apache.org (HELO mail-relay.apache.org) (140.211.11.15) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 12 May 2015 08:46:58 +0000 Received: from mail-wg0-f42.google.com (mail-wg0-f42.google.com [74.125.82.42]) by mail-relay.apache.org (ASF Mail Server at mail-relay.apache.org) with ESMTPSA id 9642F1A0155 for ; Tue, 12 May 2015 08:46:58 +0000 (UTC) Received: by wgbhc8 with SMTP id hc8so462451wgb.2 for ; Tue, 12 May 2015 01:46:57 -0700 (PDT) X-Received: by 10.194.2.47 with SMTP id 15mr28315986wjr.101.1431420417192; Tue, 12 May 2015 01:46:57 -0700 (PDT) MIME-Version: 1.0 Received: by 10.28.185.81 with HTTP; Tue, 12 May 2015 01:46:36 -0700 (PDT) In-Reply-To: References: From: Robert Metzger Date: Tue, 12 May 2015 10:46:36 +0200 Message-ID: Subject: Re: [DISCUSS] Merging Storm compatibility to Flink-contrib To: "dev@flink.apache.org" Content-Type: multipart/alternative; boundary=047d7b3a89067dbebc0515de89a2 --047d7b3a89067dbebc0515de89a2 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: quoted-printable Hi, Thank you for starting the discussion Marton! I would really like to merge the storm compat to our source repo. I think that code which is not merged there will not get enough attention. I'm against splitting flink-contrib into small maven modules. I totally understand your reasoning (mixed dependencies), but "flink-staging" exists exactly for that purpose (one maven module per "beta"-module). For now, users depending on flink-contrib have to define exclusions to control the dependencies. So I'm +1 for merging it to "flink-contrib". I guess not all committers have time to look into the pull request, therefore, I want to remind you that the code contains a lot of TODOs and UnsupportedOperationExceptions. @Marton: Do you know anybody from the Budapest Flink Streaming crew with some Storm experience who could try out the code on a cluster and give some feedback? On Tue, May 12, 2015 at 9:52 AM, M=C3=A1rton Balassi wrote: > The purpose of flink-contrib currently is to hold contributions to the > project that we do not consider part of the core flink functionality, but > provide useful tools around it. In general code placed here has to meet > less requirements in terms of covering all corner cases if it provides a > nice solution for a set of well defined problems. > > As of today it has two small utilities, the TweetInputFormat (by Mustafa > Elbehery) and the collect functionality for the DataStream (by Gabor > Gevay). > > The pull request for the Storm compatibility layer (by Matthias J. Sax) [= 1] > raises the issue as it is way more code to maintain and is more complex i= n > general that how the community would like to handle these in terms of > distribution. Do we want to have it in the Flink repository or maybe in a > separate one. > > I am personally really for having the Storm compatibility layer under > flink-contrib as Matthias is very active on the mailing list and has also > expressed his interest of further developing the functionality of the > compatibility layer. To top that a couple of users got excited about the > new feature, so I see no risk in having this code in the main repository. > > As for the structure of flink-contrib I would have the contents separated > to slim as possible maven projects, to make sure that the users only get > the dependencies that they really need. > > [1] https://github.com/apache/flink/pull/573 > --047d7b3a89067dbebc0515de89a2--