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 56F52200C62 for ; Tue, 11 Apr 2017 10:07:48 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 55A4E160B89; Tue, 11 Apr 2017 08:07:48 +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 A6A95160BAB for ; Tue, 11 Apr 2017 10:07:47 +0200 (CEST) Received: (qmail 36820 invoked by uid 500); 11 Apr 2017 08:07:46 -0000 Mailing-List: contact issues-help@ignite.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@ignite.apache.org Delivered-To: mailing list issues@ignite.apache.org Received: (qmail 36809 invoked by uid 99); 11 Apr 2017 08:07:46 -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, 11 Apr 2017 08:07:46 +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 865A21AF8B6 for ; Tue, 11 Apr 2017 08:07:46 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd2-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -100.002 X-Spam-Level: X-Spam-Status: No, score=-100.002 tagged_above=-999 required=6.31 tests=[RP_MATCHES_RCVD=-0.001, SPF_PASS=-0.001, USER_IN_WHITELIST=-100] autolearn=disabled 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 c4ZX7S3YEdfy for ; Tue, 11 Apr 2017 08:07:45 +0000 (UTC) Received: from mailrelay1-us-west.apache.org (mailrelay1-us-west.apache.org [209.188.14.139]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTP id 3F2486227F for ; Tue, 11 Apr 2017 08:07:44 +0000 (UTC) Received: from jira-lw-us.apache.org (unknown [207.244.88.139]) by mailrelay1-us-west.apache.org (ASF Mail Server at mailrelay1-us-west.apache.org) with ESMTP id 9D40FE0D67 for ; Tue, 11 Apr 2017 08:07:43 +0000 (UTC) Received: from jira-lw-us.apache.org (localhost [127.0.0.1]) by jira-lw-us.apache.org (ASF Mail Server at jira-lw-us.apache.org) with ESMTP id A4C8A240A9 for ; Tue, 11 Apr 2017 08:07:42 +0000 (UTC) Date: Tue, 11 Apr 2017 08:07:42 +0000 (UTC) From: "Vladimir Ozerov (JIRA)" To: issues@ignite.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Updated] (IGNITE-1971) Refactor various streamers implementations MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 archived-at: Tue, 11 Apr 2017 08:07:48 -0000 [ https://issues.apache.org/jira/browse/IGNITE-1971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vladimir Ozerov updated IGNITE-1971: ------------------------------------ Fix Version/s: (was: 2.0) 2.1 > Refactor various streamers implementations > ------------------------------------------ > > Key: IGNITE-1971 > URL: https://issues.apache.org/jira/browse/IGNITE-1971 > Project: Ignite > Issue Type: Bug > Components: streaming > Affects Versions: 1.5.0.final > Reporter: Denis Magda > Fix For: 2.1 > > > Re-visit streamers implementations and should address at least the following points below. > 1) {{start}} method in streamers implementations throws {{IllegalArgumentException}}. > According to the contract of IllegalArgumentException this exception is thrown only when an invalid argument is passed into the function. However no argument is passed to the method at all and we shouldn't throw this exception from this point of execution. > My suggestion is to use org.apache.ignite.IgniteIllegalStateException if we don't find better alternative. See how it's used in Ignite.ignite() method description. > 2) Streamers perform the same basics checks in their implementation of {{start}} method. > It makes sense to add {{start}} method to StreamAdapter and perform there basic checks that are the same for every streamer. -- This message was sent by Atlassian JIRA (v6.3.15#6346)