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 088F5200CBE for ; Fri, 7 Jul 2017 15:59:56 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 07076169213; Fri, 7 Jul 2017 13:59:56 +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 4CC4E169211 for ; Fri, 7 Jul 2017 15:59:55 +0200 (CEST) Received: (qmail 22337 invoked by uid 500); 7 Jul 2017 13:59:54 -0000 Mailing-List: contact issues-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@flink.apache.org Delivered-To: mailing list issues@flink.apache.org Received: (qmail 22327 invoked by uid 99); 7 Jul 2017 13:59:54 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd1-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 07 Jul 2017 13:59:54 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd1-us-west.apache.org (ASF Mail Server at spamd1-us-west.apache.org) with ESMTP id EEBA0C274F for ; Fri, 7 Jul 2017 13:59:53 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -3.78 X-Spam-Level: X-Spam-Status: No, score=-3.78 tagged_above=-999 required=6.31 tests=[KAM_LAZY_DOMAIN_SECURITY=1, KAM_LOTSOFHASH=0.25, RCVD_IN_DNSWL_HI=-5, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, T_RP_MATCHES_RCVD=-0.01] autolearn=disabled Received: from mx1-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd1-us-west.apache.org [10.40.0.7]) (amavisd-new, port 10024) with ESMTP id FDz-lH41lRjj for ; Fri, 7 Jul 2017 13:59:53 +0000 (UTC) Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with SMTP id 249E05F2AB for ; Fri, 7 Jul 2017 13:59:51 +0000 (UTC) Received: (qmail 22324 invoked by uid 99); 7 Jul 2017 13:59:51 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 07 Jul 2017 13:59:51 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 628DCE383A; Fri, 7 Jul 2017 13:59:49 +0000 (UTC) From: tillrohrmann To: issues@flink.incubator.apache.org Reply-To: issues@flink.incubator.apache.org Message-ID: Subject: [GitHub] flink pull request #4281: [FLINK-7108] [yarn] Add YARN entry points based on... Content-Type: text/plain Date: Fri, 7 Jul 2017 13:59:49 +0000 (UTC) archived-at: Fri, 07 Jul 2017 13:59:56 -0000 GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4281 [FLINK-7108] [yarn] Add YARN entry points based on the generic entry point This PR is based on #4259, #4260, #4261 and #4272. Add the YarnSesssionClusterEntrypoint and the YarnJobClusterEntrypoint which extend SessionClusterEntrypoint and JobClusterEntrypoint, respectively. Add new Yarn session and per-job cluster entry points Remove old Flip-6 Yarn per job entry point You can merge this pull request into a Git repository by running: $ git pull https://github.com/tillrohrmann/flink yarnEntrypoints Alternatively you can review and apply these changes as the patch at: https://github.com/apache/flink/pull/4281.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #4281 ---- commit 6c313e0ecc8ff84aee9403acbc60efa31d49f69e Author: Till Rohrmann Date: 2017-07-04T21:15:52Z [FLINK-7103] [dispatcher] Add skeletal structure of Dispatcher component The Dispatcher is responsible for receiving job submissions, persisting the JobGraphs, spawning JobManager to execute the jobs and recovering the jobs in case of a master failure. This commit adds the basic skeleton including the RPC call for job submission. Add cleanup logic for finished jobs Pass BlobService to JobManagerRunner commit 44abd04f328a60d3d25f74454ad04bd5c79fc258 Author: Till Rohrmann Date: 2017-07-05T11:38:35Z [FLINK-7105] Make ActorSystems non daemonic In order to not having to explicitly wait on the termination of an ActorSystem in the main thread, we now create the ActorSystems in non-daemonic mode. That way the process won't terminate if there is still an active actor. commit 4a2b08645a2e7d80c7404b6af6f396178de19e33 Author: Till Rohrmann Date: 2017-07-06T15:16:18Z [FLINK-7082] Add generic entry point for session and per-job clusters commit 3768ca597e40230da4edc75fa6b6f3203e4ee313 Author: Till Rohrmann Date: 2017-07-06T15:16:54Z [FLINK-7086] Add Flip-6 standalone session cluster entry point commit cb52bb4ea730529125556de6dc1201b90472eee7 Author: Till Rohrmann Date: 2017-07-05T15:16:52Z [FLINK-7108] [yarn] Add YARN entry points based on the generic entry point Add the YarnSesssionClusterEntrypoint and the YarnJobClusterEntrypoint which extend SessionClusterEntrypoint and JobClusterEntrypoint, respectively. Add new Yarn session and per-job cluster entry points Remove old Flip-6 Yarn per job entry point ---- --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastructure@apache.org or file a JIRA ticket with INFRA. ---