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 40C6D18300 for ; Tue, 19 Jan 2016 14:27:13 +0000 (UTC) Received: (qmail 24791 invoked by uid 500); 19 Jan 2016 14:27:13 -0000 Delivered-To: apmail-flink-dev-archive@flink.apache.org Received: (qmail 24733 invoked by uid 500); 19 Jan 2016 14:27:13 -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 24722 invoked by uid 99); 19 Jan 2016 14:27:13 -0000 Received: from Unknown (HELO spamd3-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 19 Jan 2016 14:27:13 +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 98FBE1804F3 for ; Tue, 19 Jan 2016 14:27:12 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 1 X-Spam-Level: * X-Spam-Status: No, score=1 tagged_above=-999 required=6.31 tests=[KAM_LAZY_DOMAIN_SECURITY=1] autolearn=disabled Received: from mx1-us-east.apache.org ([10.40.0.8]) by localhost (spamd3-us-west.apache.org [10.40.0.10]) (amavisd-new, port 10024) with ESMTP id sfWxVC19na0l for ; Tue, 19 Jan 2016 14:26:57 +0000 (UTC) Received: from mx2.mailbox.org (mx2.mailbox.org [80.241.60.215]) by mx1-us-east.apache.org (ASF Mail Server at mx1-us-east.apache.org) with ESMTPS id 2D1CB42BCC for ; Tue, 19 Jan 2016 14:26:57 +0000 (UTC) Received: from smtp1.mailbox.org (smtp1.mailbox.org [80.241.60.240]) (using TLSv1.2 with cipher ECDHE-RSA-AES256-GCM-SHA384 (256/256 bits)) (No client certificate requested) by mx2.mailbox.org (Postfix) with ESMTPS id 25718420B6 for ; Tue, 19 Jan 2016 15:26:50 +0100 (CET) X-Virus-Scanned: amavisd-new at heinlein-support.de Received: from smtp1.mailbox.org ([80.241.60.240]) by hefe.heinlein-support.de (hefe.heinlein-support.de [91.198.250.172]) (amavisd-new, port 10030) with ESMTP id UN9lv08rE8gW for ; Tue, 19 Jan 2016 15:26:49 +0100 (CET) To: dev@flink.apache.org From: "Matthias J. Sax" Subject: Emitting to non-declared output stream X-Enigmail-Draft-Status: N1110 Message-ID: <569E4769.8070901@apache.org> Date: Tue, 19 Jan 2016 15:25:45 +0100 User-Agent: Mozilla/5.0 (X11; Linux x86_64; rv:38.0) Gecko/20100101 Icedove/38.5.0 MIME-Version: 1.0 Content-Type: multipart/signed; micalg=pgp-sha256; protocol="application/pgp-signature"; boundary="aSrBRgcKPvH7c2GAVSJcFi7xL3th3uIe8" --aSrBRgcKPvH7c2GAVSJcFi7xL3th3uIe8 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: quoted-printable Hi, currently, I am using Storm 0.9.3. For first tests on a new topology, I use LocalCluster. It happened to me, that I emitted tuples to an output stream, that I did never declare (and thus not connect to). For this, I would expect an error message in the log. However, I don't get anything which makes debugging very hard. What do you think about it? Should I open a JIRA for it? For real cluster deployment, I think the overhead of checking the output stream ID is too large and one can easily see the problem in the UI -- the non-declared output streams that gets tuples show up there. However, for LocalCluster, there is not UI and an error log message would be nice.= -Matthias --aSrBRgcKPvH7c2GAVSJcFi7xL3th3uIe8 Content-Type: application/pgp-signature; name="signature.asc" Content-Description: OpenPGP digital signature Content-Disposition: attachment; filename="signature.asc" -----BEGIN PGP SIGNATURE----- Version: GnuPG v2 iQIcBAEBCAAGBQJWnkdxAAoJEFCVK48prEZ4sx0QAPFa/oCt3ZykI2wUn9zt9ilH WFKQkzJdGDDYSJN4OK/thnUEiGecEQEeiGDUo3q7ZNiRh2fcDgN/wH1FL54NPsmo WUfdPVuDC4sbMuiE2vuZTo/2A7BdB/WtRDJdTpYW/hmCE4NkdsvzhVQC+j+h1wJm Vtt3ia1tM5bztkSxXKi+iKQAGMTTzvTiH5kgfX1F9gFHt5UV5J2fIQTVtmNumJc8 tfsS5tFbh2Rt73+5dRJ795QYkIdMPnbSekxsFVzwO6ZsaOf9Gu+JPtAfJy1U3noR in9qMy5IRJyBrbwLndwobGey7EvQkpzGU36b+HBnS+gidKdYoTgAHnLM/6xaQRD5 cCtkzSg7gbC4MzgQi3q1XtbP+HjYZj/5zL4fSyL1nL5zdWQHSr+Z9F2bFkDkh7VD vCAtPVH8QZ5cI8+tVvu1ta+2NvuuoywljkiIE9MShVKtQd4M/z4Ctj5bljEmflJ8 7By9gcnfTtH4sOTuOnDnDG4gcgu9d2E0BnV+7IboZlvvBMcGIohfcav2tyGGXmYZ V+4LoWawYfE6JVrOe38/MXQZq3F8lnwFdArjZl15OyPHkRrQ1dYgn3tGo1LXXyxF tEvV5Ge4YSDeH65RB1wSL22Q9QN/JLuF2wkkAQEA6f8VnSk+KKVS3UNS9WmJoy5y yr+ESsQ409v+NizUtZwo =jdqD -----END PGP SIGNATURE----- --aSrBRgcKPvH7c2GAVSJcFi7xL3th3uIe8--