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 C96D0200CC2 for ; Wed, 21 Jun 2017 01:44:40 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id C888E160BEF; Tue, 20 Jun 2017 23:44:40 +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 1A563160BE1 for ; Wed, 21 Jun 2017 01:44:39 +0200 (CEST) Received: (qmail 1714 invoked by uid 500); 20 Jun 2017 23:44:34 -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 1703 invoked by uid 99); 20 Jun 2017 23:44:34 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd4-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 20 Jun 2017 23:44:34 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd4-us-west.apache.org (ASF Mail Server at spamd4-us-west.apache.org) with ESMTP id C03D9C0311 for ; Tue, 20 Jun 2017 23:44:33 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -11.505 X-Spam-Level: X-Spam-Status: No, score=-11.505 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, FORGED_MUA_MOZILLA=1.596, HTML_MESSAGE=2, RCVD_IN_DNSWL_NONE=-0.0001, SPF_PASS=-0.001, USER_IN_DEF_WHITELIST=-15] autolearn=disabled Authentication-Results: spamd4-us-west.apache.org (amavisd-new); dkim=pass (1024-bit key) header.d=yahoo-inc.com Received: from mx1-lw-us.apache.org ([10.40.0.8]) by localhost (spamd4-us-west.apache.org [10.40.0.11]) (amavisd-new, port 10024) with ESMTP id 2zgBpzA90mbf for ; Tue, 20 Jun 2017 23:44:32 +0000 (UTC) Received: from sonic327-12.consmr.mail.ne1.yahoo.com (sonic327-12.consmr.mail.ne1.yahoo.com [66.163.188.35]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTPS id 0753D5F283 for ; Tue, 20 Jun 2017 23:44:31 +0000 (UTC) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=yahoo-inc.com; s=ginc1024; t=1498002264; bh=LgOYy4u3HdcFkAj4Ulye44fDA7vhDLCr9pU+F7QrMkA=; h=Date:From:Reply-To:To:Subject:References:From:Subject; b=iC144hRr7oZcq9aY6/GJAe+IGefT54MPtfKxV9HASbU2Ybqpc8LmK/cbf/xxYv7r+0BlG4woA7KKpnBovqZF6sK8Dy1Nl/wvzvEbY1FENMavJyY7NVL3H8F28dd31ucrXyPodq57bfO3Wp4U7sFdLK4Hx8mrMa+eSiKpmI4OxSg= X-YMail-OSG: HuxjRdUVM1ljd9Oxs6ffZDbjGczMZkfIB9o4HnTT2l5iNa0Zhd7sScMYcYWnU3Q nAiVihpmSry5dDt7xdtQpurVApzD70UoGaEOFmFmcfMkqcQ9y0iIq9ETtoSNuV_SDurb4vUmFJpk OB0YKu91OsXccG06QKY3yRFqJqb0yo58Yxf7paqPraSswP0OUMsq62QHa2DHhBBNucz2TWDOOwLJ 4YAWbY9f0YdJv5B4flZ_Bi0Im6l1bknaT16ecX8n2kNYmPYBC66a0okKto5z_Hy5r9xo6Ig-- Received: from sonic.gate.mail.ne1.yahoo.com by sonic327.consmr.mail.ne1.yahoo.com with HTTP; Tue, 20 Jun 2017 23:44:24 +0000 Date: Tue, 20 Jun 2017 23:44:15 +0000 (UTC) From: Will Walters Reply-To: Will Walters To: User Message-ID: <1658099776.2748547.1498002255972@mail.yahoo.com> Subject: Session ID Error MIME-Version: 1.0 Content-Type: multipart/alternative; boundary="----=_Part_2748546_1823306000.1498002255971" References: <1658099776.2748547.1498002255972.ref@mail.yahoo.com> X-Mailer: WebService/1.1.9911 YahooMailNeo Mozilla/5.0 (Macintosh; Intel Mac OS X 10_12_5) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/58.0.3029.110 Safari/537.36 archived-at: Tue, 20 Jun 2017 23:44:41 -0000 ------=_Part_2748546_1823306000.1498002255971 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 7bit Hello, In attempting to submit a job via Yarn session on Hadoop cluster (using Flink 1.2.1), I get timed out and receive the following error from the server: Discard message LeaderSessionMessage(00000000-0000-0000-0000-000000000000,SubmitJob(JobGraph(jobId: 5d0406fc547af4fc36bf78ed812a3f90),EXECUTION_RESULT_AND_STATE_CHANGES)) because the expected leader session ID None did not equal the received leader session ID Some(00000000-0000-0000-0000-000000000000).This seems to be an issue with the way that a Null session ID is handled. Is there a way to manually set the session ID? Any advice would be greatly appreciated. Thank you,Will Walters. ------=_Part_2748546_1823306000.1498002255971 Content-Type: text/html; charset=UTF-8 Content-Transfer-Encoding: quoted-printable
Hello,
<= div id=3D"yui_3_16_0_ym19_1_1497979736050_82807">
=
In attempting to submi= t a job via Yarn session on Hadoop cluster (using Flink 1.2.1), I get timed= out and receive the following error from the server:

<= /font>
Disca=
rd message LeaderSessionMessage(00000000-0000-0000-0000-000000000000,Submit=
Job(JobGraph(jobId: 5d0406fc547af4fc36bf78ed812a3f90),EXECUTION_RESULT_AND_=
STATE_CHANGES)) because the expected leader session ID None did not equal t=
he received leader session ID Some(00000000-0000-0000-0000-000000000000).
This seems to be an issu=
e with the way that a Null session ID is handled. Is there a way to manuall=
y set the session ID? Any advice would be greatly appreciated.
=

Thank you,
Will Walters.

------=_Part_2748546_1823306000.1498002255971--