Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id C1E4E200C45 for ; Tue, 28 Mar 2017 10:01:50 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id C068B160B7E; Tue, 28 Mar 2017 08:01:50 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 148B2160B89 for ; Tue, 28 Mar 2017 10:01:49 +0200 (CEST) Received: (qmail 93098 invoked by uid 500); 28 Mar 2017 08:01:48 -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 92677 invoked by uid 99); 28 Mar 2017 08:01:48 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd2-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 28 Mar 2017 08:01:48 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd2-us-west.apache.org (ASF Mail Server at spamd2-us-west.apache.org) with ESMTP id B3B341A7A6F; Tue, 28 Mar 2017 08:01:47 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd2-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 2.379 X-Spam-Level: ** X-Spam-Status: No, score=2.379 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, HTML_MESSAGE=2, RCVD_IN_DNSWL_NONE=-0.0001, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, RCVD_IN_SORBS_SPAM=0.5, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd2-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gmail.com Received: from mx1-lw-us.apache.org ([10.40.0.8]) by localhost (spamd2-us-west.apache.org [10.40.0.9]) (amavisd-new, port 10024) with ESMTP id Ck4w5U4tXhiB; Tue, 28 Mar 2017 08:01:46 +0000 (UTC) Received: from mail-yw0-f172.google.com (mail-yw0-f172.google.com [209.85.161.172]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTPS id C2F6B5FC7E; Tue, 28 Mar 2017 08:01:45 +0000 (UTC) Received: by mail-yw0-f172.google.com with SMTP id d191so48004808ywe.2; Tue, 28 Mar 2017 01:01:45 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20161025; h=mime-version:in-reply-to:references:from:date:message-id:subject:to :cc; bh=T4i1PovYhsPIRMNvxRVrSKwSQ9tMmsxsa4K5ezlhTFw=; b=gy8rQcP6ybRcSjd7ehM6LPvpnAQiRVfd7XR1QEIWlwLQal5KQyDs73ktj4/43ARq0x goSTvcOB+KfEjE+cHdgbao7itqZVZ312x8dyt8vPeC0sY1o+yTXwI8IM9yL1vQFuRFcn 9vBTNHyDspe+7MkIUi/M/XwX9aeWrr9NCPtKiWd7ZdRMYme3pq20Oea0b3FZzFtSxBsB rBD7y6NyOTTBRmuVDgT/rB6hAbCHz8al/gqophQ9RgOlepU1DUHl2hFxbSoJTrnYisvK Wk56Nq6DFGsgsgvsS6LeRXgaYPqnjCS1WBAhz3ZEkxebY4AKJ2EwPtyHbiZ8oSAzkfLX UE1g== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:mime-version:in-reply-to:references:from:date :message-id:subject:to:cc; bh=T4i1PovYhsPIRMNvxRVrSKwSQ9tMmsxsa4K5ezlhTFw=; b=AP2MfMjfuyDkbK4dY/U5oEhpOOmZ6pa+OGoclScRJjX5kuJJbnks2nJE/ye/eZufVW ieUhSmO4JduxlKA/uvp09vrblsfjpzqI5Q1eDVAffdL71vrw8D15o/nCTH1nXFB+2A2q qe0qSJxw551x9PPS1scqW0VLzHds2Sdx7fw0tFumHw5aXtJjOOoEMwThDv3pHAJsj9Zm /xif87z6qZbx535QCDqhPjvS0gsySnmmkx4XcETbKyph4BCEil3vK1lZ7LVliTaUMAy6 zMQfHeCbTF3nsnjrMhwBpeGQAUh0AboDVrC32Ae/MQr47OKqFqysm6pZfRv6y9VfSpR3 lOug== X-Gm-Message-State: AFeK/H3yiA/My3POHmwCu8GtRu5NanAV2IbvFyXfgzw9NtLuHcgW8V4O/OQOq4iOkgCpLnlPVaFXU3heWUPKVg== X-Received: by 10.129.175.27 with SMTP id n27mr21635627ywh.229.1490688099211; Tue, 28 Mar 2017 01:01:39 -0700 (PDT) MIME-Version: 1.0 Received: by 10.83.31.7 with HTTP; Tue, 28 Mar 2017 01:01:08 -0700 (PDT) In-Reply-To: References: From: Fabian Hueske Date: Tue, 28 Mar 2017 10:01:08 +0200 Message-ID: Subject: Re: Java library for Flink-Kudu integration To: "dev@flink.apache.org" Cc: "user@flink.apache.org" Content-Type: multipart/alternative; boundary=f403045ee3949fe6a5054bc5de5c archived-at: Tue, 28 Mar 2017 08:01:50 -0000 --f403045ee3949fe6a5054bc5de5c Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: quoted-printable No, we do not want to move all connectors to Apache Bahir or replace the connectors by Bahir. The Flink community aims to maintain the most important connectors within Flink. Maintaining all connectors would be a huge effort. So, we decided to move some of the less frequently used connectors to Bahir. Best, Fabian 2017-03-28 8:31 GMT+02:00 shijinkui : > Hi, Fabian > Do we have plan to replace Flink connectors with bahir-flink[1]? > > [1] https://github.com/apache/Bahir-flink > > =E5=9C=A8 2017/3/28 =E4=B8=8A=E5=8D=8812:15=EF=BC=8C "Fabian Hueske" =E5=86=99=E5=85=A5: > > >Hi Ruben, > > > >thanks for sharing this! > >A Flink Kudu connector is a great contribution and Bahir seems to be the > >right place for it. > > > >Thanks, Fabian > > > > > >2017-03-27 15:35 GMT+02:00 : > > > >> Hi all, > >> > >> I apologize for sending the email to both accounts, but not sure where > >> this topic fits better. > >> > >> In my team, we have been working in some PoCs and PoVs about new data > >> architectures. As part of this work, we have implemented a library to > >> connect Kudu and Flink. The library allows reading/writing from/to Kud= u > >> tablets using DataSet API and also writing to Kudu using DataStream AP= I. > >> > >> You can find the code and documentation (including some examples) in > >> https://github.com/rubencasado/Flink-Kudu > >> > >> Any comment/suggestion/contribution is very welcomed =E2=98=BA > >> > >> We will try to publish this contribution to the Apache Bahir project. > >> > >> Best > >> > >> ---------------------------------------- > >> Rub=C3=A9n Casado Tejedor, PhD > >> > accenture digital > >> Big Data Manager > >> ' + 34 629 009 429 > >> =E2=80=A2 ruben.casado.tejedor@accenture.com >> casado.tejedor@accenture.com> > >> > >> ________________________________ > >> > >> This message is for the designated recipient only and may contain > >> privileged, proprietary, or otherwise confidential information. If you > >>have > >> received it in error, please notify the sender immediately and delete > >>the > >> original. Any other use of the e-mail by you is prohibited. Where > >>allowed > >> by local law, electronic communications with Accenture and its > >>affiliates, > >> including e-mail and instant messaging (including content), may be > >>scanned > >> by our systems for the purposes of information security and assessment > >>of > >> internal compliance with Accenture policy. > >> ____________________________________________________________ > >> __________________________ > >> > >> www.accenture.com > >> > > --f403045ee3949fe6a5054bc5de5c--