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 CE563200D2D for ; Fri, 27 Oct 2017 20:30:41 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id CCF8F160BF2; Fri, 27 Oct 2017 18:30:41 +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 1EEDB1609DD for ; Fri, 27 Oct 2017 20:30:40 +0200 (CEST) Received: (qmail 58775 invoked by uid 500); 27 Oct 2017 18:30:40 -0000 Mailing-List: contact user-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Delivered-To: mailing list user@flink.apache.org Received: (qmail 58765 invoked by uid 99); 27 Oct 2017 18:30:39 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd3-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 27 Oct 2017 18:30:39 +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 0F8EE180236 for ; Fri, 27 Oct 2017 18:30:39 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 0.48 X-Spam-Level: X-Spam-Status: No, score=0.48 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, RCVD_IN_DNSWL_NONE=-0.0001, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, RCVD_IN_SORBS_SPAM=0.5] autolearn=disabled Authentication-Results: spamd3-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=intellifylearning-com.20150623.gappssmtp.com Received: from mx1-lw-us.apache.org ([10.40.0.8]) by localhost (spamd3-us-west.apache.org [10.40.0.10]) (amavisd-new, port 10024) with ESMTP id LgH3-wwk6QRZ for ; Fri, 27 Oct 2017 18:30:35 +0000 (UTC) Received: from mail-qk0-f173.google.com (mail-qk0-f173.google.com [209.85.220.173]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTPS id 7281B5FB0B for ; Fri, 27 Oct 2017 18:30:35 +0000 (UTC) Received: by mail-qk0-f173.google.com with SMTP id d67so9442513qkg.5 for ; Fri, 27 Oct 2017 11:30:35 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=intellifylearning-com.20150623.gappssmtp.com; s=20150623; h=from:content-transfer-encoding:mime-version:subject:message-id:date :to; bh=YqOh7H1SDcbP6yC3GuU4wCY5R/azb+G1p1lSGNCu+fI=; b=lAmkI2HkHP9sWCoA0glQ9F0AcwWEEfqsgaV+De8QD61BcgLMhu2YHEr79Sck7+cOR7 JbjhOPAU2xDWSN2dbpNlRR47jDE9SkdmqQZXpi/fnnYf7+3m8yScWX3iHabF5lNeIyec kzLc1TH4Xtfrnh+KHuBbfHgB7d2owIrMF8HW40rV+s0u/MLLIRK2WvfeuLkwTwlFSVlc hUO45SW4LT7uBfHCc3QrDwDQdZRfIzvsp71c4mAkjlmVPYE75eAdBRszbx+9sCAXk2UO PSXLzgYyuUmaLwBgN6k2S0Wy0AZYkXAW8YyC/kRf/E2dRx81vy7nnsjTiYgM1jYmZjmt 6BJA== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:from:content-transfer-encoding:mime-version :subject:message-id:date:to; bh=YqOh7H1SDcbP6yC3GuU4wCY5R/azb+G1p1lSGNCu+fI=; b=GkEU5Kd+KgiL96/wgaiTJPxebnIj2yWQKXpDP4+MXLyETtTgazt8YwX+cDyvof2rBu EsSqPnIvnqoyXpQR33ULyUXPGyVS5K+Z1ApoHyAH7xLoAlh3VWjnAdu0Ei/j28yMJzGY sMZp8Ffph3CEIvhGuVKDkvCoWEMIWaysaXz/elU45B5lvrZmv4C4O8mBnDRoSmiWZB6V SCzGvwT4YgMBvlwkL0YbzwzeqolSjdiS8Zkxuy4klyjBFmAMuPl/wFBe2ZR6YXunVZyj eZuixfhfbIHbf71iy2E40UaX6mDJkUFY3lTZE+m9VUQXWy3fdLphIHICVNT6PnlMIuz7 D5zQ== X-Gm-Message-State: AMCzsaXHvYenXG2OiVBZnyipksxrm2TKLL5THgxFnNnywpkcxPv4YcCk eIqtKG1bPrh0MJlBGB+qzk9IqfUZFg== X-Google-Smtp-Source: ABhQp+QCYUCGpfrzIdwK6RQQRqPVSTtlKw3g8fNfpEZD8awNGpV1pDQ/2/elZVAABANsQE+SYinykg== X-Received: by 10.55.166.77 with SMTP id p74mr2213508qke.264.1509129034814; Fri, 27 Oct 2017 11:30:34 -0700 (PDT) Received: from [192.168.1.3] (c-71-232-51-138.hsd1.ma.comcast.net. [71.232.51.138]) by smtp.gmail.com with ESMTPSA id i12sm5540820qkh.83.2017.10.27.11.30.34 for (version=TLS1_2 cipher=ECDHE-RSA-AES128-GCM-SHA256 bits=128/128); Fri, 27 Oct 2017 11:30:34 -0700 (PDT) From: Jared Stehler Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: quoted-printable Mime-Version: 1.0 (Mac OS X Mail 10.3 \(3273\)) Subject: Programmatic way to determine required number of slots for a job? Message-Id: Date: Fri, 27 Oct 2017 14:30:33 -0400 To: user@flink.apache.org X-Mailer: Apple Mail (2.3273) archived-at: Fri, 27 Oct 2017 18:30:42 -0000 Is there a way to determine via an API the required number of task = manager slots for a particular job graph? I=E2=80=99ve looked at = "flink.getStreamGraph().getJobGraph().getNumberOfVertices()=E2=80=9D but = it doesn=E2=80=99t seem to correspond with what the job actually ends up = using. -- Jared Stehler Chief Architect - Intellify Learning o: 617.701.6330 x703