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 038FB200BF8 for ; Fri, 13 Jan 2017 09:59:59 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id 020B6160B3F; Fri, 13 Jan 2017 08:59:59 +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 43375160B32 for ; Fri, 13 Jan 2017 09:59:58 +0100 (CET) Received: (qmail 93393 invoked by uid 500); 13 Jan 2017 08:59:57 -0000 Mailing-List: contact user-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@flink.apache.org Delivered-To: mailing list user@flink.apache.org Received: (qmail 93384 invoked by uid 99); 13 Jan 2017 08:59:57 -0000 Received: from mail-relay.apache.org (HELO mail-relay.apache.org) (140.211.11.15) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 13 Jan 2017 08:59:57 +0000 Received: from mail-oi0-f46.google.com (mail-oi0-f46.google.com [209.85.218.46]) by mail-relay.apache.org (ASF Mail Server at mail-relay.apache.org) with ESMTPSA id 020281A01D7 for ; Fri, 13 Jan 2017 08:59:57 +0000 (UTC) Received: by mail-oi0-f46.google.com with SMTP id w204so51151327oiw.0 for ; Fri, 13 Jan 2017 00:59:56 -0800 (PST) X-Gm-Message-State: AIkVDXIGgobxRb5cW1zAZiPvBWRFq7ZCoTKRLlvi7qDHm15QideovfY0IdH/dzPjAzex+clYgFaxYbGnF5qKwbI0 X-Received: by 10.202.45.9 with SMTP id t9mr9401990oit.132.1484297996504; Fri, 13 Jan 2017 00:59:56 -0800 (PST) MIME-Version: 1.0 Received: by 10.157.46.23 with HTTP; Fri, 13 Jan 2017 00:59:16 -0800 (PST) In-Reply-To: References: From: Ufuk Celebi Date: Fri, 13 Jan 2017 09:59:16 +0100 X-Gmail-Original-Message-ID: Message-ID: Subject: Re: 1.1.4 on YARN - vcores change? To: user@flink.apache.org Content-Type: text/plain; charset=UTF-8 archived-at: Fri, 13 Jan 2017 08:59:59 -0000 On Fri, Jan 13, 2017 at 9:57 AM, Robert Metzger wrote: > Flink is reading the number of available vcores from the local YARN > configuration. Is it possible that the YARN / Hadoop config on the machine > where you are submitting your job from sets the number of vcores as 4 ? Shouldn't we retrieve this number from the cluster instead?