Return-Path: X-Original-To: apmail-flink-user-archive@minotaur.apache.org Delivered-To: apmail-flink-user-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id CA8761889F for ; Wed, 6 Apr 2016 07:26:33 +0000 (UTC) Received: (qmail 99792 invoked by uid 500); 6 Apr 2016 07:26:33 -0000 Delivered-To: apmail-flink-user-archive@flink.apache.org Received: (qmail 99703 invoked by uid 500); 6 Apr 2016 07:26:33 -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 99693 invoked by uid 99); 6 Apr 2016 07:26:33 -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; Wed, 06 Apr 2016 07:26:33 +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 13D6A180554 for ; Wed, 6 Apr 2016 07:26:33 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 3.982 X-Spam-Level: *** X-Spam-Status: No, score=3.982 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, HTML_MESSAGE=2, PYZOR_CHECK=1.985, RCVD_IN_DNSWL_NONE=-0.0001, RCVD_IN_MSPIKE_H2=-0.001, SPF_HELO_PASS=-0.001, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd3-us-west.apache.org (amavisd-new); dkim=pass (1024-bit key) header.d=cern.onmicrosoft.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 iu4chNWdGGNb for ; Wed, 6 Apr 2016 07:26:32 +0000 (UTC) Received: from emea01-db3-obe.outbound.protection.outlook.com (mail-db3on0090.outbound.protection.outlook.com [157.55.234.90]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTPS id 92F705F1B3 for ; Wed, 6 Apr 2016 07:26:31 +0000 (UTC) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=cern.onmicrosoft.com; s=selector1-cern-ch; h=From:To:Date:Subject:Message-ID:Content-Type:MIME-Version; bh=8DKs4779T8Zi+DIdOZ5Z1bklhesGAKR4mojSeuGgRhE=; b=bneidY9+4qGwJ0VnWkPd2RCNUbQ9rDwy4mLqgA8Ijo75LcyMGDIpzGcUyX4MWAHlmCZNFFD7XF+/tyF23eHZgowH1/EC5YYkwxYTW9RFgerFavWnzS9QWYak6gV5Z9qFzYzm+RRQAR5RXRQr9R9ue0FuEU7R2/aBvbldoZ8duRI= Received: from HE1PR06CA0104.eurprd06.prod.outlook.com (10.169.114.30) by VI1PR06MB1471.eurprd06.prod.outlook.com (10.164.86.25) with Microsoft SMTP Server (TLS) id 15.1.447.15; Wed, 6 Apr 2016 07:26:23 +0000 Received: from AM1FFO11OLC009.protection.gbl (2a01:111:f400:7e00::166) by HE1PR06CA0104.outlook.office365.com (2a01:111:e400:7a1b::30) with Microsoft SMTP Server (TLS) id 15.1.453.26 via Frontend Transport; Wed, 6 Apr 2016 07:26:23 +0000 Authentication-Results: spf=pass (sender IP is 188.184.36.50) smtp.mailfrom=cern.ch; flink.apache.org; dkim=none (message not signed) header.d=none;flink.apache.org; dmarc=bestguesspass action=none header.from=cern.ch; Received-SPF: Pass (protection.outlook.com: domain of cern.ch designates 188.184.36.50 as permitted sender) receiver=protection.outlook.com; client-ip=188.184.36.50; helo=CERNMX11.cern.ch; Received: from CERNMX11.cern.ch (188.184.36.50) by AM1FFO11OLC009.mail.protection.outlook.com (10.174.65.123) with Microsoft SMTP Server (TLS) id 15.1.453.6 via Frontend Transport; Wed, 6 Apr 2016 07:26:22 +0000 Received: from cernfe05.cern.ch (188.184.36.45) by cernmxgwlb4.cern.ch (188.184.36.50) with Microsoft SMTP Server (TLS) id 14.3.158.1; Wed, 6 Apr 2016 09:25:49 +0200 Received: from CERNXCHG72.cern.ch ([fe80::6956:202c:8040:6710]) by CERNFE05.cern.ch ([fe80::7062:4836:3950:8c53%11]) with mapi id 14.03.0174.001; Wed, 6 Apr 2016 09:25:49 +0200 From: Serhiy Boychenko To: "user@flink.apache.org" Subject: Running Flink jobs directly from Eclipse Thread-Topic: Running Flink jobs directly from Eclipse Thread-Index: AdGP1YqEPILpSvC2S2ujaI9dBjENhw== Date: Wed, 6 Apr 2016 07:25:49 +0000 Message-ID: <19AFC5ED17E4454D8442AF13BC8DA64507B10BCE@CERNXCHG72.cern.ch> Accept-Language: en-GB, en-US Content-Language: en-US X-MS-Has-Attach: X-MS-TNEF-Correlator: x-originating-ip: [137.138.114.169] Content-Type: multipart/alternative; boundary="_000_19AFC5ED17E4454D8442AF13BC8DA64507B10BCECERNXCHG72cernc_" MIME-Version: 1.0 X-EOPAttributedMessage: 0 X-Forefront-Antispam-Report: CIP:188.184.36.50;IPV:NLI;CTRY:CH;EFV:NLI;SFV:NSPM;SFS:(10009020)(6009001)(2980300002)(438002)(189002)(199003)(2930100002)(586003)(2906002)(16236675004)(2900100001)(2501003)(102836003)(5250100002)(1096002)(1220700001)(6116002)(790700001)(6806005)(2920100001)(33656002)(15975445007)(3846002)(5003600100002)(66066001)(5004730100002)(19300405004)(450100001)(260700001)(87936001)(110136002)(229853001)(2351001)(19625215002)(189998001)(107886002)(92566002)(106466001)(512954002)(74482002)(84326002)(11100500001)(53416004)(19580395003)(5001970100001)(5008740100001)(86362001)(50986999)(16796002)(54356999)(55846006);DIR:OUT;SFP:1101;SCL:1;SRVR:VI1PR06MB1471;H:CERNMX11.cern.ch;FPR:;SPF:Pass;MLV:sfv;MX:1;A:1;LANG:en; X-Microsoft-Exchange-Diagnostics: 1;AM1FFO11OLC009;1:/z2ecc80rhMOsnZrRvj308svNRuIT0fap0H59AcPLVNMvYOdiezR8Vvm1GtkzPeMceg5RQOPB3FrwJOOtuZh4k2wo71SpY5suHWUHJGwJZ8Occ798B1wo1aqN7CRClKW2t72PAiucwyoKfaYj+HXJcg4WmebmRsOefCXNwq7AeNDoXcnDHVb67iPHOVB/T1p+iN//QReGuTyO8THeTV/KGnf52VVDTcS7R7MCxZtAtOxKX4OXAZa6RBmgtaRbXQxWw4EXm2tmWFnfWoIxNuA8s2zehON9EPFkevwb+2s4mwcrVAnI/sbM4Kl7e/YAcvn8qPXJ2O0kPMtsoSNfgrhQ/vfWy3lAchRShLZUnnCb6aETIA7UcbcjDG9LLfmhfBVDe6KqY2/JuGFHmHnCYWCNJIgvp6AG456dP+THmqg001JQz9pX7w1sIuh9LjtqmmZXDrf4aql9hcAESBKspaR6GWy3xPdktP+BarweBdkU5K6G963TWnD+tbhZn71OX81 X-MS-Office365-Filtering-Correlation-Id: 87c93edc-afe5-48d4-6a33-08d35decc162 X-Microsoft-Exchange-Diagnostics: 1;VI1PR06MB1471;2:Be6gdgft1dHgWE7vPRFTbEoUJ5d6iwRHR1CaeBoiufBObW/gOie/9mY3mCwbd3NxE9vY7TDn5dlToRQr0qBSXXZBXl4qz/3BFcae+3w7XhqZAPmWcJ18m4emZkfNC8Px9DGmWRXOezivnui91DkdX8Ol5B4wrKab+ozjLfD/SxFLzGp1vT+gtCd8JqtmUJOs;3:swNsDSZSAEMXUq0NEpFg70LEZU2K3NZHkl2cjxolXIl2i/3L62e0u5yamQMsTNn6t69eiPfr4jkvqJ7Fk2wzaLgGFU91LxGz+9r9wTxMQlG68UIUNP9yo+MBRysuwXHjaJRtl0bYuTMR2FJedFPrQfTRqwiXSQA7T6WWNHZTie+0DJQxaSbEk9cTYJcjC50lOGUJAAt6LXMLnjAgNlfRSMua2P0MOSdehuWLpodGswG3541iYUxToD1XsQreYKqil5PpiADGKTq3nU1gGMcxWw==;25:f0ysbhUHZLlBsfXYdDpvuk5XchJHiNt+hEXot6cHTcPK4ZtxQiPtzRg4U5UWOR5GCgpoDtMDoqTl/UCOk3soswac7l1qZSMenY9YxPQCzUYwmlcCzMOukE2FRw4hulCsCS16eAjT2raS+rNq5FbJilCB+vGTzHuFLHK6sHdQwTJJ4N4LAVilFmXVzhf3fYnJMMMN8S8AGDMXRA1VjuhHlRuwQHcIaIl6Lj24HwvfYntzE7hUOFLXPRonwjGApFF39bmj0eHistAS6WnhmevdwKs9BFl49vohYnvZ8JDa7BxvbSh/QE5iOreBHML9eBjFB9sRXSS5Vy5P8XFZwq0/Yw== X-Microsoft-Antispam: UriScan:;BCL:0;PCL:0;RULEID:(8251501002);SRVR:VI1PR06MB1471; X-Microsoft-Exchange-Diagnostics: 1;VI1PR06MB1471;20:bfJQ+EBTYvH54SzmgI0J+EHMddRA+jRe7QZVjzJlXSk3h2+j8qGKVo9T/pKuSB+FFRRrclWqeKaICRbdPZLHcpNk7ufo8ruFJaWZ22aOHt8+6nCbCyUTxjkLedjmnwKD73g9jO1UgwiKrpTKKpQrlJ4eXSaVHCXF5vUhNpliXY/+9GjmTwF7aFel0T/t1JpoVhRYVarni9Vq3P6cDaRRz6iD+JcyQiZRSwPwWl1fol6gYJZtJv6tb0XzjWp/2PoldCuIwWqwbxoI9b4IBKAlK39wTGL5vOF+Z8Wo94vSq9olxgws5lnVhjRw+6G15au57OetIhvf4MezcJnKkkdMOz9TAidpjxc/XwQ+iFvlkkClyK6tbLv+cm7CaP5OTC2GEP8WD9X95OiEpbwdxqVDkdanPo4dpLoZ5T70yeLHEDU0jbhynaQJtDw85B1yCPngbqE6XUgClOyGdcN8UKeC6L3fJ8IqKnn2im9MvasPzY2DDwhKlPUJwridw+S2LUw4;4:cEnuatX9TYBF9CJLXxCno/CQYcUi0Eupqppo7tW4AB/ULcUwASSZZllEChvZ1DhLbpPuZqq30kF5jypUuFg4I+xebBeL/v2sT64KStU9yi/XKPweyHLRq23jo346YX6aRlWTNfZWiL4yMTKoFAkVqc3bz8MaMrb93PQnSBz7gzISOayEMRPpR7aCjRoeqdASlmAxzm3mKMhuLrlIiu07qGFjcQ4SKDbkKB6d8oiCpYyGmphfRhO88uABo1EavjK9kamdOzMcJLaALJ6AE6erIx3K9+JqE78+MJ6zsidXl7p5knotPbu7VU6zAzPl9QddVXgolR2l+oVc+M6HfmVT4ISgnW79joWqwaa1SgxPR6C7/yxoni6nIhCnq7cEv3C8CtGcW15m+TL11YklFU6/dJ7j4o5olgB596TcrKpUIxHzjRH771DOwvi/Nade/agX X-Microsoft-Antispam-PRVS: X-Exchange-Antispam-Report-Test: UriScan:; X-Exchange-Antispam-Report-CFA-Test: BCL:0;PCL:0;RULEID:(601004)(2401047)(13024025)(13018025)(5005006)(8121501046)(13023025)(13016025)(10201501046)(3002001);SRVR:VI1PR06MB1471;BCL:0;PCL:0;RULEID:;SRVR:VI1PR06MB1471; X-Forefront-PRVS: 0904004ECB X-Microsoft-Exchange-Diagnostics: =?us-ascii?Q?1;VI1PR06MB1471;23:9sCFjEnUPtVBoLjDJnVbcJxgilVKs/smYj+wW0wEU?= =?us-ascii?Q?a+DXTTn3W5AggJs/DGSi+gwj+F11BuGr8TogKLbO+zZGRZhWIgRwv7hlcrFl?= =?us-ascii?Q?knTN9NNKQu85tOnmLEbEDTrc8nfEn/h0OdJldMyWLIEAo6owzae2O9XpR3H6?= =?us-ascii?Q?VoqZoHmcFntxN7Hlo1IuNPky5EoRKnR1d5tSH8PGofOWhGJDXJE2L1Y49JMJ?= =?us-ascii?Q?oKqYgfKsrojhu5ID0VhDUWxmnAtvuMXHzIfX6YOJyl97jGUs7KyA6AQCcBGB?= =?us-ascii?Q?1rGpu42X/JLu3zx2EWkg+9PC67pkTIKUcNEO3qMNnifkV+2sIh4hEQodjpyM?= =?us-ascii?Q?jf8KAVb3dSmECgSTH29wuRivr6vxSqndh/7teVG1cap6aq0s4KshmX1dq258?= =?us-ascii?Q?O16JKXfJsqFuTB8JU/LFLa3TwS7JUFSwWXOURpWBC97UnWaSTjlzFxnFVOGM?= =?us-ascii?Q?MqlTEcWcJBNFgVV/yeuduWnflkx1dVM/CBgy+ZHOiolpcj0CXUMy0Vb7fyPP?= =?us-ascii?Q?I/3frEvk66U1tKIxLmJ3c4d/JeRbQrtE91YyIBKt8bRJE41mA291ZXa2vh1b?= =?us-ascii?Q?ABbFH8bdt8oSFDqhdky5LvIsWtbWf7aFdb4a2VWmoy6Gf7z8WJhIyt3dD1h6?= =?us-ascii?Q?FdbEVFzwUUNgIjt7lQXS6tTssp5zw04B45LNh85J7CkqHnUuGfztZVlCO/7k?= =?us-ascii?Q?IgU/S9FT1Ts7czUKuisngtAQt6Ypd7mSwI90QiSEDlVGc6yKuS/GGOQuq+x7?= =?us-ascii?Q?wwdV0EZNY6QuTf4U8Li0TFoqZkTC27icz4lpqbtuHRbN95QDzKexzAwd6dh+?= =?us-ascii?Q?bLMjTQ7jvQ5CJ5/wciuduGHRCXrr5FNzMuqSqpt79/WYHSOAZI+1nl2KkvYB?= =?us-ascii?Q?hU8//RdJFw3c5vjxZmEes/IRDvSNO3MA4i4CETd0KabFw4K5jTFXrDvVAkzq?= =?us-ascii?Q?4XIg5VTy5uxqfQqJhiR1zf1NSb2/Z3byfoEU8VXS78E6axtseuErP9N3yq/D?= =?us-ascii?Q?hhW+8t6ArmWSXAwM8+CRxcYMHRWLE4588Lu0JS8oFKLgEpgygk+ZxH15fyxT?= =?us-ascii?Q?R129LB61jGbj6lw5a85lYCBt2r0nh3pTaFx7cy4i9yg/tCyOZ4FMAy3mKx+R?= =?us-ascii?Q?/CMw1jDEn44KQww/Hc0e8ofpI/el/txlXWr7OoTvtbC3lyWq3Gjc0il8dZ8a?= =?us-ascii?Q?Yca0r/l3Xsu3NCkC5M6qHAygxFfGPxIfAp5lEvXRQM/zLxBsbD/Bi3ziC7Th?= =?us-ascii?Q?cMKC99ACUXkRKaFcjPNT+wP3vn082XLwV0hTIfxUXeYzFdsoTK0ILp/DlP7X?= =?us-ascii?Q?zwJJwPehBK5XljKrf5Zr3I=3D?= X-Microsoft-Exchange-Diagnostics: 1;VI1PR06MB1471;5:5CU7Jp+YygM/hXepVh5FHGcQ3bkELG1bt5H4RieiGF2meuh9bTsQQ7vjPwFHu7MpF0uel78DUZQj5/UT+UYeK1+rtuBCWmzxkneedOhtlZHUSockS64e2e2MKYYNPoDWQKvT+07jz0yLt9xmSrhOEw==;24:9UnDTbeDfIL6LwnBBGeFHVPIkofly9hITkClK17v4+QKfu1r2Zf4ZxHfMKQy96csuauRshFIFVWkyoAoEWI+WfqTGSqhFKykNKw9u4+QYUI= SpamDiagnosticOutput: 1:23 SpamDiagnosticMetadata: NSPM X-OriginatorOrg: cern.ch X-MS-Exchange-CrossTenant-OriginalArrivalTime: 06 Apr 2016 07:26:22.4993 (UTC) X-MS-Exchange-CrossTenant-Id: c80d3499-4a40-4a8c-986e-abce017d6b19 X-MS-Exchange-CrossTenant-OriginalAttributedTenantConnectingIp: TenantId=c80d3499-4a40-4a8c-986e-abce017d6b19;Ip=[188.184.36.50];Helo=[CERNMX11.cern.ch] X-MS-Exchange-CrossTenant-FromEntityHeader: HybridOnPrem X-MS-Exchange-Transport-CrossTenantHeadersStamped: VI1PR06MB1471 --_000_19AFC5ED17E4454D8442AF13BC8DA64507B10BCECERNXCHG72cernc_ Content-Type: text/plain; charset="us-ascii" Content-Transfer-Encoding: quoted-printable Cheerz, I have been working last few month on the comparison of different data proc= essing engines and recently came across Apache Flink. After reading differe= nt academic papers on comparison of Flink with other data processing I woul= d definitely give it a shot. The only issue I am currently having is that I= am unable to submit Flink jobs directly from Eclipse (to YARN cluster). I = am wondering if you got any guildelines how I could do the submission not f= rom the client but from Eclipse directly? (I was unable to find anything re= lated, with the exception of setting up Eclipse for working on Flink core) Best regards, Serhiy. --_000_19AFC5ED17E4454D8442AF13BC8DA64507B10BCECERNXCHG72cernc_ Content-Type: text/html; charset="us-ascii" Content-Transfer-Encoding: quoted-printable

Cheerz,

 

I have been working last few month on the comparison= of different data processing engines and recently came across Apache Flink= . After reading different academic papers on comparison of Flink with other= data processing I would definitely give it a shot. The only issue I am currently having is that I am unable t= o submit Flink jobs directly from Eclipse (to YARN cluster). I am wondering= if you got any guildelines how I could do the submission not from the clie= nt but from Eclipse directly? (I was unable to find anything related, with the exception of setting up Ecli= pse for working on Flink core)

 

Best regards,

Serhiy.

 

--_000_19AFC5ED17E4454D8442AF13BC8DA64507B10BCECERNXCHG72cernc_--