From user-return-11762-apmail-storm-user-archive=storm.apache.org@storm.apache.org Thu Sep 8 16:02:46 2016 Return-Path: X-Original-To: apmail-storm-user-archive@minotaur.apache.org Delivered-To: apmail-storm-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 95BEA19A93 for ; Thu, 8 Sep 2016 16:02:46 +0000 (UTC) Received: (qmail 39079 invoked by uid 500); 8 Sep 2016 16:02:45 -0000 Delivered-To: apmail-storm-user-archive@storm.apache.org Received: (qmail 39034 invoked by uid 500); 8 Sep 2016 16:02:45 -0000 Mailing-List: contact user-help@storm.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@storm.apache.org Delivered-To: mailing list user@storm.apache.org Received: (qmail 39024 invoked by uid 99); 8 Sep 2016 16:02:45 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd1-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 08 Sep 2016 16:02:45 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd1-us-west.apache.org (ASF Mail Server at spamd1-us-west.apache.org) with ESMTP id C1232C9B76 for ; Thu, 8 Sep 2016 16:02:44 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 1.576 X-Spam-Level: * X-Spam-Status: No, score=1.576 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_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, RCVD_IN_SORBS_SPAM=2.397, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd1-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gmail.com Received: from mx1-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd1-us-west.apache.org [10.40.0.7]) (amavisd-new, port 10024) with ESMTP id zIeETNnRK92C for ; Thu, 8 Sep 2016 16:02:42 +0000 (UTC) Received: from mail-wm0-f44.google.com (mail-wm0-f44.google.com [74.125.82.44]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with ESMTPS id 490AE5F30B for ; Thu, 8 Sep 2016 16:02:42 +0000 (UTC) Received: by mail-wm0-f44.google.com with SMTP id 1so97703806wmz.1 for ; Thu, 08 Sep 2016 09:02:42 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:from:date:message-id:subject:to; bh=zrOh2P3YxXPSrwwQPwW8nX6CcoiQymnMea9qolSDTLg=; b=EzEyF+xPZHjjFCEIfzrEYsap79su7p0WaCuLLakbu0zxlhWikKhA33XFWdoBq4DFij HJbwYIHuWk9qa+/Aq2A7vLqN73ahLU31pl6psN2ft0+JZ038JBZhRD9p9xXa3GZYAMjG xgy39EQRr/5/b5IQRHn7XRKxi+EHp0iSTMKYQn9hhejLdBtI0e+1cZtJi802ULU039MH 5Ws9rxOxy4uPqGoIktL1jzX1FpDvSBp1XzQlPfoAUb2A/bbtHv/TzH4u0DKNxNLPKFV7 t8KWfwy46O6llSFJqdoyV55TvBraBa52f2peneUVzdwjewWTV3xuXDzSCiolib0QnVpE qinQ== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20130820; h=x-gm-message-state:mime-version:from:date:message-id:subject:to; bh=zrOh2P3YxXPSrwwQPwW8nX6CcoiQymnMea9qolSDTLg=; b=YmEx1HQ/rs5fg5Wh8JkWjWML56a7eSNFQm91zUHw56/cC9NUsq328qBlpkFOO+1dSW IXnlyaTrIn45XJrIjtmMexsSpNQoPwTTKFyUJTAjhQ/0x7UcWA8Hjnti2IqLDHSe2iiA o7BQOUmq07ZteqQpqeDyXTTp6fiSktK6R+8sy6R83F1wQ5MN0yw7FuzZF/3UmDkraOO7 3iogU9M1W5GCRKFyi2lRPgbVj2kJjf6Qi42nYLjTc9LBufc2NZjTXpNezlhU6KMCiVRx xIz45vSeeEw1irJSmdh3yhnYdHCxqiA+BTOdgCVMHMqN0iV7T1u7/h9XrTGi+hk31kWC cJCA== X-Gm-Message-State: AE9vXwOfSKDRsaijs5nGI6olb7wKRPpPj/26pXqknjwv4U8wbRzVIvJE9ym9v6uQd8izqpEFzzoIaRHmBXJAYQ== X-Received: by 10.28.68.136 with SMTP id r130mr1130005wma.4.1473350561814; Thu, 08 Sep 2016 09:02:41 -0700 (PDT) MIME-Version: 1.0 Received: by 10.28.144.75 with HTTP; Thu, 8 Sep 2016 09:02:41 -0700 (PDT) From: John Lukar Date: Thu, 8 Sep 2016 12:02:41 -0400 Message-ID: Subject: Kestrel integration with Storm 1.0.1 using KestrelThriftSpout while upgrading from storm 0.82 To: user@storm.apache.org Content-Type: text/plain; charset=UTF-8 Storm website documentation (http://storm.apache.org/about/integrates.html) implies KestrelThriftSpout should work out of the box: https://github.com/nathanmarz/storm-kestrel However 1.0.1's builder.setSpout, does not accept KTS which is based on backtype.* package naming which was storm 0.82 package name. The code below will not compile with the message: "Wrong 2nd argument type. Found: 'backtype.storm.spout.KestrelThriftSpout', required: 'org.apache.storm.topology.IRichSpout' ..." KTS implements "backtype.storm.topology.IRichSpout" Do I need to fork KestrelThriftSpout and port to new Apache 1.0.1 (new org.apache pacakage names) or there is another KTS that works with Storm 1.0.1 ? Thanks in advance for your help !! TopologyBuilder builder = new TopologyBuilder(); builder.setSpout( name, new KestrelThriftSpout( hostsList, Integer.parseInt(topologyConfig.getProperty(TOPOLOGY_PORTNUM)), name, new MySchemeImpl() ), Integer.parseInt(topologyConfig.getProperty(SPOUT_PARALLELISM)));