Return-Path: X-Original-To: apmail-samza-dev-archive@minotaur.apache.org Delivered-To: apmail-samza-dev-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 7DB121026F for ; Tue, 25 Nov 2014 06:58:44 +0000 (UTC) Received: (qmail 62048 invoked by uid 500); 25 Nov 2014 06:58:44 -0000 Delivered-To: apmail-samza-dev-archive@samza.apache.org Received: (qmail 61995 invoked by uid 500); 25 Nov 2014 06:58:44 -0000 Mailing-List: contact dev-help@samza.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@samza.incubator.apache.org Delivered-To: mailing list dev@samza.incubator.apache.org Received: (qmail 61984 invoked by uid 99); 25 Nov 2014 06:58:44 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 25 Nov 2014 06:58:44 +0000 X-ASF-Spam-Status: No, hits=2.2 required=5.0 tests=HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_NEUTRAL X-Spam-Check-By: apache.org Received-SPF: neutral (athena.apache.org: local policy) Received: from [209.85.214.177] (HELO mail-ob0-f177.google.com) (209.85.214.177) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 25 Nov 2014 06:58:38 +0000 Received: by mail-ob0-f177.google.com with SMTP id va2so8163882obc.22 for ; Mon, 24 Nov 2014 22:58:16 -0800 (PST) X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20130820; h=x-gm-message-state:mime-version:date:message-id:subject:from:to :content-type; bh=UtZoeANRIYVyK3Ymu4QM4wuWykG3X/+7pmI3JfHD3iY=; b=JCZY+Y6BlutTbLgPY2lfvIVnMiC+vc9+3eTi2SB5gQCV2Xab/cjL2yI9c9eMCx1RZJ ZVu2qXAAg1i2eA33eGXU+XeWYndfTmryJnbTnUL9eNod6x8sfvLLqzylm9tZ3XT/F8aw gjBSIWQzI8wU+ys+gVOv5d1T2iKA/NMhB3NGPKarHb82SqWx3Do4SIDED0YJVHY8zYLp 5O0CGXeRbwqX6zeWT0qXE4caJdlXdV/9BAGPeLyE8KeYSfva+LtlWW+twzttLf8epYEL HD/247qzlm9luLR0p2PXzfqup00F1v4Gz6kB3RfVcW7n5TRey8i7SOgaMzKVFH1Q/mjy NxOA== X-Gm-Message-State: ALoCoQmRwtwyyJPZ4x/K8zUe76LOEPbbgUPVQPJwvA6LazL6uc+KCleKaFbYNfJJG43oWlW/GP7l MIME-Version: 1.0 X-Received: by 10.182.79.104 with SMTP id i8mr14475380obx.58.1416898696122; Mon, 24 Nov 2014 22:58:16 -0800 (PST) Received: by 10.76.127.100 with HTTP; Mon, 24 Nov 2014 22:58:16 -0800 (PST) Date: Tue, 25 Nov 2014 08:58:16 +0200 Message-ID: Subject: Mutiple tasks running in a single container From: Dotan Patrich To: dev@samza.incubator.apache.org Content-Type: multipart/alternative; boundary=047d7b2e3d687725400508a96f45 X-Virus-Checked: Checked by ClamAV on apache.org --047d7b2e3d687725400508a96f45 Content-Type: text/plain; charset=UTF-8 Hi, We run a topology that contains multiple tasks and plan to add more to it in the near future. However, one of the key design issues that I considering is how granular should each samza task should be: on the one hand have granular tasks helps integrating them at different parts of the topology, however on the other hand each task has it's own basic JVM memory requirement that restrict how many tasks a machine can host. One thing I noticed in the documentation is that each samza container can host several tasks? "The SamzaContainer is responsible for managing the startup, execution, and shutdown of one or more StreamTask instances" I thought this could be some sort of workaround to the memory concerns I have (assuming cpu consumption of the streaming task will work out ok). Can anyone share how to host several tasks in a single container? Are those only tasks instances for different partitions or can it be different tasks all together? Thanks, Dotan --047d7b2e3d687725400508a96f45--