Return-Path: X-Original-To: apmail-flink-user-archive@minotaur.apache.org Delivered-To: apmail-flink-user-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 860A619C8C for ; Wed, 13 Apr 2016 23:25:50 +0000 (UTC) Received: (qmail 46036 invoked by uid 500); 13 Apr 2016 23:25:50 -0000 Delivered-To: apmail-flink-user-archive@flink.apache.org Received: (qmail 45942 invoked by uid 500); 13 Apr 2016 23:25:50 -0000 Mailing-List: contact user-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@flink.apache.org Delivered-To: mailing list user@flink.apache.org Received: (qmail 45931 invoked by uid 99); 13 Apr 2016 23:25:50 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd3-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 13 Apr 2016 23:25:50 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd3-us-west.apache.org (ASF Mail Server at spamd3-us-west.apache.org) with ESMTP id BF99018044E for ; Wed, 13 Apr 2016 23:25:49 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -0.803 X-Spam-Level: X-Spam-Status: No, score=-0.803 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, RCVD_IN_DNSWL_LOW=-0.7, RCVD_IN_MSPIKE_H2=-0.001, RP_MATCHES_RCVD=-0.001, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd3-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=yahoo.com Received: from mx2-lw-us.apache.org ([10.40.0.8]) by localhost (spamd3-us-west.apache.org [10.40.0.10]) (amavisd-new, port 10024) with ESMTP id ngF9avFCy2iD for ; Wed, 13 Apr 2016 23:25:48 +0000 (UTC) Received: from nm46-vm2.bullet.mail.gq1.yahoo.com (nm46-vm2.bullet.mail.gq1.yahoo.com [67.195.87.170]) by mx2-lw-us.apache.org (ASF Mail Server at mx2-lw-us.apache.org) with ESMTPS id D514B5F1F0 for ; Wed, 13 Apr 2016 23:25:47 +0000 (UTC) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=yahoo.com; s=s2048; t=1460589946; bh=yC0tUUD2mrUTPTqhslkoYcOlzCAEMqE1On4kr3oyNOA=; h=Date:From:Reply-To:To:Subject:References:From:Subject; b=Gz1OrhBcKA7pJpL3OwSsb+dN7HpUrVmUVa00ZgFcsR95qF6wzbOGPgxKlS6ixjkS6om4Noylu5akQLmyaAKkP0sWxestg+uZrLSS/sFjI4mnOUaNR2FXg51SUKx4/12YNbRhYobjjDrBYz+NxCratrW88+Zt0guqhSn4zoeAmVIvpyX8YCs3VHYaGpRMs8PYgfR3mNh/6lSPlTkkF9OKHoQ8k45zFVVaxeRlnwO+gFWMRHo7YZQ3cIshdY0kX60R0EKCmpwXpBobDx37lniPNFrdlC8INiIWOgMO0EAwVelfVMiOgk9Aqw+nqMjOlVvmd4pGlYwKHof81PImGcWwcA== Received: from [127.0.0.1] by nm46.bullet.mail.gq1.yahoo.com with NNFMP; 13 Apr 2016 23:25:46 -0000 Received: from [98.137.12.58] by nm46.bullet.mail.gq1.yahoo.com with NNFMP; 13 Apr 2016 23:22:49 -0000 Received: from [98.137.12.201] by tm3.bullet.mail.gq1.yahoo.com with NNFMP; 13 Apr 2016 23:22:49 -0000 Received: from [127.0.0.1] by omp1009.mail.gq1.yahoo.com with NNFMP; 13 Apr 2016 23:22:49 -0000 X-Yahoo-Newman-Property: ymail-4 X-Yahoo-Newman-Id: 461195.94843.bm@omp1009.mail.gq1.yahoo.com X-YMail-OSG: gHzTeY4VM1kTo7sQk6jscLvP9nC6._A.wKQSE.GeHpgoXcPXJwuTZ318N9szrd. iRFjkFNnVH7mVRuyXXKu.MiUrSqD2gS6nMOYojyBO7FgVGQcvR8yJDUx42BuEQutsp.cJz6uYI5c f0Zc8C5kBtwVGXrA4S7f6GxDo8ucI5Wn5JDD9v1.9igv0IYBcRrvF2t5Miyan9GiyInKDWUulJLL Wr76oC0EYSJU0CCdLYrwqQ1C6TqHkBlK3V3GUzy5jGgyeqc0Lbv1O08rDm8AGYREfJDnhYZuebuR Vx0svtjBH0AJ5wqDCwyhNLWb88zyD_yKAPPuRUZ8jsTc6kgqjsPuK0M83I6FVZqPHcngn_TMS06R avXwmGlt5em6kVtLdFQdJG2mmUwdzgolX4nhx41RtbCQ8cm1D9eMnwY0MTTVG5qR_xtU_kqWyoda DPNW9vOL7LzOpmSM3juTt8s4VV5RRj0GR_m1Or.KRc_zWi6CbSw4E3ezmMAIDIpa9Sf10wxPc7JH T.HkCEL387oNvQXDH6hFn Received: by 98.137.12.50; Wed, 13 Apr 2016 23:22:49 +0000 Date: Wed, 13 Apr 2016 23:22:48 +0000 (UTC) From: neo21 zerro Reply-To: neo21 zerro To: "user@flink.apache.org" Message-ID: <648210496.134639.1460589768796.JavaMail.yahoo@mail.yahoo.com> Subject: Sink partitioning MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 7bit References: <648210496.134639.1460589768796.JavaMail.yahoo.ref@mail.yahoo.com> Hello everybody, I have an elasticsearch sink in my flink topology. My requirement is to write the data in a partitioned fashion to my Sink. For example I have Tuple which contains a user id. I want to group all events by a user id and partition all events for one particular user to the same Es Sink. Is it possible to achieve something like this in Flink? Thanks!