Return-Path: X-Original-To: apmail-zookeeper-user-archive@www.apache.org Delivered-To: apmail-zookeeper-user-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id CEC53105EA for ; Wed, 2 Sep 2015 08:47:45 +0000 (UTC) Received: (qmail 7981 invoked by uid 500); 2 Sep 2015 08:47:45 -0000 Delivered-To: apmail-zookeeper-user-archive@zookeeper.apache.org Received: (qmail 7931 invoked by uid 500); 2 Sep 2015 08:47:45 -0000 Mailing-List: contact user-help@zookeeper.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@zookeeper.apache.org Delivered-To: mailing list user@zookeeper.apache.org Received: (qmail 7919 invoked by uid 99); 2 Sep 2015 08:47:44 -0000 Received: from Unknown (HELO spamd3-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 02 Sep 2015 08:47:44 +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 6499D18230B for ; Wed, 2 Sep 2015 08:47:44 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 2.898 X-Spam-Level: ** X-Spam-Status: No, score=2.898 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, HTML_MESSAGE=3, RCVD_IN_MSPIKE_H2=-0.001, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd3-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gmail.com Received: from mx1-eu-west.apache.org ([10.40.0.8]) by localhost (spamd3-us-west.apache.org [10.40.0.10]) (amavisd-new, port 10024) with ESMTP id FyOxtR5LM125 for ; Wed, 2 Sep 2015 08:47:43 +0000 (UTC) Received: from mail-ig0-f172.google.com (mail-ig0-f172.google.com [209.85.213.172]) by mx1-eu-west.apache.org (ASF Mail Server at mx1-eu-west.apache.org) with ESMTPS id 3DE5921567 for ; Wed, 2 Sep 2015 08:47:42 +0000 (UTC) Received: by igbkq10 with SMTP id kq10so20325917igb.0 for ; Wed, 02 Sep 2015 01:47:41 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:date:message-id:subject:from:to:content-type; bh=4C9kHmXZoRvtYPnubDwz489Aa/KpwiVax9D/WbqWbVo=; b=X1aQ2pBnOe5WDtQYDRMSzz571y9dIW1mc07RPd9GrR53RQgPy4n+tLhkImYUipT097 jCeZg1sYCVf1HQhmGvwQDS7BkWuKZjzVndwj07GKIerswKMxKlcY/PCGJGuXQg8u3a0T Jv4T4iSm10P+npcrWO4DUQ/WFunelbG6Ul1NYu7v9AHS0qHwPBJNPFe5C2cRsEqxYuud oxxbbVKLf2O0qj4yWPphyFmTc+emMY5Xqq+s3//bhNwuDA43fYUjfivUwvBewQchDUYU XwJiPKHakchNcXtYmMc5GYsAqVetLpf4pub1uGGohukHoaIXuiC9IwTRC+Fj4bpiYcCT werg== MIME-Version: 1.0 X-Received: by 10.50.72.6 with SMTP id z6mr2238817igu.65.1441183661211; Wed, 02 Sep 2015 01:47:41 -0700 (PDT) Received: by 10.79.13.145 with HTTP; Wed, 2 Sep 2015 01:47:41 -0700 (PDT) Date: Wed, 2 Sep 2015 14:17:41 +0530 Message-ID: Subject: Distributed Task Queue with client node failovers From: Prabhjot Bharaj To: user@zookeeper.apache.org Content-Type: multipart/alternative; boundary=047d7bdc189a2ec6c6051ebfb8ea --047d7bdc189a2ec6c6051ebfb8ea Content-Type: text/plain; charset=UTF-8 Hello Folks, I am trying to design a distributed queue with Zookeeper. The use case is like this:- A set of 't' tasks to be executed by 'n' nodes in round-robin fashion. But, if any node goes down, the other nodes should take the task. For this purpose, I'm reading about zookeeper Queue recipe. The Queue recipe relies on client watcher. Initially, all clients run their respective tasks. But, after one iteration, lets say one client node goes down. In this case, that client node itself is unavailable to get a Watch Event, can the task be transferred to another node ? The worst case will be - All the client nodes, but one, are down. Can this one node still pick up all tasks sequentially and execute them ? Thanks, Prabhjot --047d7bdc189a2ec6c6051ebfb8ea--