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 B1525200BCC for ; Tue, 29 Nov 2016 07:34:13 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id AFE7F160B15; Tue, 29 Nov 2016 06:34:13 +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 07740160B05 for ; Tue, 29 Nov 2016 07:34:12 +0100 (CET) Received: (qmail 86269 invoked by uid 500); 29 Nov 2016 06:34:11 -0000 Mailing-List: contact issues-help@eagle.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@eagle.incubator.apache.org Delivered-To: mailing list issues@eagle.incubator.apache.org Received: (qmail 86260 invoked by uid 99); 29 Nov 2016 06:34:11 -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; Tue, 29 Nov 2016 06:34:11 +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 41880180254 for ; Tue, 29 Nov 2016 06:34:11 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -7.019 X-Spam-Level: X-Spam-Status: No, score=-7.019 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=-2.999] autolearn=disabled Received: from mx1-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd3-us-west.apache.org [10.40.0.10]) (amavisd-new, port 10024) with ESMTP id OcdVri5cBkJH for ; Tue, 29 Nov 2016 06:34:10 +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 76B2F5F3BA for ; Tue, 29 Nov 2016 06:34:09 +0000 (UTC) Received: (qmail 86231 invoked by uid 99); 29 Nov 2016 06:34:08 -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; Tue, 29 Nov 2016 06:34:08 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 97C09DFF13; Tue, 29 Nov 2016 06:34:08 +0000 (UTC) From: chitin To: issues@eagle.incubator.apache.org Reply-To: issues@eagle.incubator.apache.org References: In-Reply-To: Subject: [GitHub] incubator-eagle pull request #691: EAGLE-796 MRJobEntityCreationHandler flus... Content-Type: text/plain Message-Id: <20161129063408.97C09DFF13@git1-us-west.apache.org> Date: Tue, 29 Nov 2016 06:34:08 +0000 (UTC) archived-at: Tue, 29 Nov 2016 06:34:13 -0000 Github user chitin commented on a diff in the pull request: https://github.com/apache/incubator-eagle/pull/691#discussion_r89948452 --- Diff: eagle-jpm/eagle-jpm-mr-running/src/main/java/org/apache/eagle/jpm/mr/running/parser/MRJobEntityCreationHandler.java --- @@ -79,10 +79,7 @@ public boolean flush() { eagleServiceConfig.password); client.getJerseyClient().setReadTimeout(eagleServiceConfig.readTimeoutSeconds * 1000); try { - LOG.info("start to flush mr job entities, size {}", entities.size()); - client.create(entities); - LOG.info("finish flushing mr job entities, size {}", entities.size()); - entities.clear(); + return createEntities(client); } catch (Exception e) { LOG.warn("exception found when flush entities, {}", e); e.printStackTrace(); --- End diff -- Done.Thanks! --- 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. ---