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 1290C200C48 for ; Thu, 6 Apr 2017 17:37:54 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 1148D160B83; Thu, 6 Apr 2017 15:37:54 +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 7CE27160B84 for ; Thu, 6 Apr 2017 17:37:53 +0200 (CEST) Received: (qmail 49661 invoked by uid 500); 6 Apr 2017 15:37:52 -0000 Mailing-List: contact user-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Delivered-To: mailing list user@flink.apache.org Received: (qmail 49645 invoked by uid 99); 6 Apr 2017 15:37:52 -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; Thu, 06 Apr 2017 15:37:52 +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 2DEA3183991 for ; Thu, 6 Apr 2017 15:37:52 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 2.232 X-Spam-Level: ** X-Spam-Status: No, score=2.232 tagged_above=-999 required=6.31 tests=[RCVD_IN_DNSWL_NONE=-0.0001, SPF_FAIL=0.919, URI_HEX=1.313] autolearn=disabled Received: from mx1-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd3-us-west.apache.org [10.40.0.10]) (amavisd-new, port 10024) with ESMTP id YDSpBOv_l_L5 for ; Thu, 6 Apr 2017 15:37:51 +0000 (UTC) Received: from mwork.nabble.com (mwork.nabble.com [162.253.133.43]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with ESMTP id 073175F1E9 for ; Thu, 6 Apr 2017 15:37:51 +0000 (UTC) Received: from mjoe.nabble.com (unknown [162.253.133.57]) by mwork.nabble.com (Postfix) with ESMTP id BB38B37E310E5 for ; Thu, 6 Apr 2017 08:37:49 -0700 (MST) Date: Thu, 6 Apr 2017 08:28:45 -0700 (PDT) From: nragon To: user@flink.apache.org Message-ID: <1491492525989-12545.post@n4.nabble.com> Subject: Shared DataStream MIME-Version: 1.0 Content-Type: text/plain; charset=us-ascii Content-Transfer-Encoding: 7bit archived-at: Thu, 06 Apr 2017 15:37:54 -0000 Hi, Can we share the end point of on job (datastream) with another job? The arquitecture I'm working on should provide abstraction and dynamism between processing jobs, which transform and load data into hbase or other sink, and cep jobs, which will be used to detect anomalies. But because the datastream of one processing job can be used to N cep jobs i wonder if sharing datastreams between jobs would be possible? Or if not, do I need to send them back to kafka. Thanks -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Shared-DataStream-tp12545.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.