From user-return-14783-archive-asf-public=cust-asf.ponee.io@storm.apache.org Sat Sep 19 16:30:57 2020 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mxout1-he-de.apache.org (mxout1-he-de.apache.org [95.216.194.37]) by mx-eu-01.ponee.io (Postfix) with ESMTPS id 7882A18066B for ; Sat, 19 Sep 2020 18:30:57 +0200 (CEST) Received: from mail.apache.org (mailroute1-lw-us.apache.org [207.244.88.153]) by mxout1-he-de.apache.org (ASF Mail Server at mxout1-he-de.apache.org) with SMTP id A1BCB63FBE for ; Sat, 19 Sep 2020 16:30:56 +0000 (UTC) Received: (qmail 35004 invoked by uid 500); 19 Sep 2020 16:30:54 -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 34994 invoked by uid 99); 19 Sep 2020 16:30:54 -0000 Received: from spamproc1-he-fi.apache.org (HELO spamproc1-he-fi.apache.org) (95.217.134.168) by apache.org (qpsmtpd/0.29) with ESMTP; Sat, 19 Sep 2020 16:30:54 +0000 Received: from localhost (localhost [127.0.0.1]) by spamproc1-he-fi.apache.org (ASF Mail Server at spamproc1-he-fi.apache.org) with ESMTP id E2213C0116 for ; Sat, 19 Sep 2020 16:30:53 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamproc1-he-fi.apache.org X-Spam-Flag: NO X-Spam-Score: -0.001 X-Spam-Level: X-Spam-Status: No, score=-0.001 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, DKIM_VALID_EF=-0.1, HTML_MESSAGE=0.2, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamproc1-he-fi.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gmail.com Received: from mx1-he-de.apache.org ([116.203.227.195]) by localhost (spamproc1-he-fi.apache.org [95.217.134.168]) (amavisd-new, port 10024) with ESMTP id 8Jr4ZKjRAtd6 for ; Sat, 19 Sep 2020 16:30:53 +0000 (UTC) Received-SPF: Pass (mailfrom) identity=mailfrom; client-ip=2607:f8b0:4864:20::12f; helo=mail-il1-x12f.google.com; envelope-from=rahilrshk@gmail.com; receiver= Received: from mail-il1-x12f.google.com (mail-il1-x12f.google.com [IPv6:2607:f8b0:4864:20::12f]) by mx1-he-de.apache.org (ASF Mail Server at mx1-he-de.apache.org) with ESMTPS id 1070A7F68F for ; Sat, 19 Sep 2020 16:30:52 +0000 (UTC) Received: by mail-il1-x12f.google.com with SMTP id q4so9445568ils.4 for ; Sat, 19 Sep 2020 09:30:52 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20161025; h=mime-version:from:date:message-id:subject:to; bh=1cD3XXg/eP9KVCSWhZqf7MGkSgOq/8Lslkr2Dg6mFP0=; b=UWwzOsyTLmWXNFv7LsAaUMXRcz1fpkvgyR2aaTHfmsJiQQiVEEwDtMzvZcQXE/2j0N NN8W103+JmuAOpzy0C5mmR7/0RGpcz3JtJI7Y4bY9N03w+xEDpcsRAqep2+HiW88Z7NQ 29U7AE8yfavt70y+e4mKGLJV6W8JhAIX96/cb4+BHRWlU2YWd4OWXWSNNx30liY5t7HS xwou3IbS7XKK1wTPVlNiN/pjcq6WJTM7Jk3umPl+n5W/O1matHxpBiF5Dc1GlZ07dTKq H0XRZIsmyny3sknYbnibeJbsuPBDdpIRjUgqcRjIEoWpG2tRqKtu/w5UtEjF5qZacedt XQeQ== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:mime-version:from:date:message-id:subject:to; bh=1cD3XXg/eP9KVCSWhZqf7MGkSgOq/8Lslkr2Dg6mFP0=; b=q/Xo8JGE8LDi/aIXDA1KomQnQjsBGpBZ0g46zUxfO7l2v4OfG1XuMi+P0rwvBjzb/k hZV73sqjRpb4D/9w8D2cXdbkQDPByeLl2NF/E3e8DZNyBbyvkMsEkMdMZEjkcDEJR6SG 5/as15FtU0rBb4HJRtr/knbdWS+Dq0IjR7zUGmGyUfRHz+Za3P9eqY+09C13kWRKs11E 4GxzDAhzZ2wbPe94nSX1W4HyAPYjR/cTRBi4SuxAEXxtIS+b9BlFqWMk80vSZjVEGwj4 UyMhb5EpOJ5GvFUQZ7KzBSvkpfRuz4hIpdXj+hUQVjVgFwdoHSjAU3Ypac9oceB7+jqs gDIQ== X-Gm-Message-State: AOAM531VNP1keG4qnfceLlZQQXBhYk6t++yf3GrMh8KfALDd+9JWA91R 4DXddc+tGJxF1pmogX2wugSdVO2an1XUuB1xKw2lGDw9pyM= X-Google-Smtp-Source: ABdhPJwFCMr1a79sYWvUS8dIthgTqHaWm1KDJqSZbGJJO/RYCMJAGhMHNR/9lgo6wSf1LEp6bVWLm76vkCPt9DIXWY8= X-Received: by 2002:a92:cb11:: with SMTP id s17mr9929540ilo.218.1600533051546; Sat, 19 Sep 2020 09:30:51 -0700 (PDT) MIME-Version: 1.0 From: Rahil Date: Sat, 19 Sep 2020 22:00:40 +0530 Message-ID: Subject: Non linear DRPC Topology To: user@storm.apache.org Content-Type: multipart/alternative; boundary="000000000000fd225c05afad23ad" --000000000000fd225c05afad23ad Content-Type: text/plain; charset="UTF-8" Hi, We have a use case where we want to trigger topology from a web service and wait for its result. The topology can have conditional/non-conditional split which may or may not be merged. I came across LinearDRPCTopologyBuilder, but as the name suggests it supports only linear topologies. We are using storm 1.2.1 and I tried CoordinatedBolt as mentioned in the Advanced section of http://storm.apache.org/releases/1.2.3/Distributed-RPC.html but I was getting IndexOutOfBoundsException. Also, I see LinearDRPCTopologyBuilder is deprecated and would like to know what this is the suggested alternative. Can you point to examples of NonLinearDRPCTopology. Regards, Rahil --000000000000fd225c05afad23ad Content-Type: text/html; charset="UTF-8" Content-Transfer-Encoding: quoted-printable
Hi,

We have a use case where we want to= trigger topology from a web service and wait for its result.=C2=A0The topo= logy can have conditional/non-conditional split which may or may not be mer= ged. I came across LinearDRPCTopologyBuilder, but as the name suggests it = supports only linear topologies. We are using storm 1.2.1 and I tried=C2=A0= CoordinatedBolt=C2=A0as mentioned in the Advanced section of= =C2=A0http://storm.apache.org/releases/1.2.3/Distributed-RPC.html but I wa= s getting=C2=A0IndexOutOfBoundsException. Also, I see LinearDRPCTopologyBui= lder is deprecated=C2=A0and would like to know what this=C2=A0is the=C2=A0s= uggested=C2=A0alternative.=C2=A0Can you point to examples of NonLinearDRPCT= opology.

Regards,
Rahil
--000000000000fd225c05afad23ad--