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 77A33200CBE for ; Fri, 7 Jul 2017 20:03:40 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 76191169AA9; Fri, 7 Jul 2017 18:03: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 BBA0B169AA8 for ; Fri, 7 Jul 2017 20:03:39 +0200 (CEST) Received: (qmail 25649 invoked by uid 500); 7 Jul 2017 18:03:38 -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 25624 invoked by uid 99); 7 Jul 2017 18:03:38 -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; Fri, 07 Jul 2017 18:03:38 +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 D1B76C0335 for ; Fri, 7 Jul 2017 18:03:37 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -4.021 X-Spam-Level: X-Spam-Status: No, score=-4.021 tagged_above=-999 required=6.31 tests=[KAM_LAZY_DOMAIN_SECURITY=1, RCVD_IN_DNSWL_HI=-5, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, RP_MATCHES_RCVD=-0.001] autolearn=disabled 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 jWHaJJY-HoS7 for ; Fri, 7 Jul 2017 18:03:37 +0000 (UTC) Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with SMTP id 7F9535F30C for ; Fri, 7 Jul 2017 18:03:36 +0000 (UTC) Received: (qmail 25602 invoked by uid 99); 7 Jul 2017 18:03:35 -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 18:03:35 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 55277E0996; Fri, 7 Jul 2017 18:03:35 +0000 (UTC) From: tillrohrmann To: issues@flink.incubator.apache.org Reply-To: issues@flink.incubator.apache.org Message-ID: Subject: [GitHub] flink pull request #4286: [FLINK-7135] [flip6] Pass in proper configuration ... Content-Type: text/plain Date: Fri, 7 Jul 2017 18:03:35 +0000 (UTC) archived-at: Fri, 07 Jul 2017 18:03:40 -0000 GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4286 [FLINK-7135] [flip6] Pass in proper configuration to Dispatcher component This PR is based on #4259, #4260 and #4261. The `Dispatcher` component should get passed in the proper `Configuration` instance from the `SessionClusterEntrypoint`. You can merge this pull request into a Git repository by running: $ git pull https://github.com/tillrohrmann/flink passInConfigurationToDispatcher Alternatively you can review and apply these changes as the patch at: https://github.com/apache/flink/pull/4286.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 #4286 ---- 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 cacde44d9cec26e77836c56782b620d2e6d4979d Author: Till Rohrmann Date: 2017-07-07T17:57:10Z [FLINK-7135] [flip6] Pass in proper configuration to Dispatcher component ---- --- 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. ---