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 7E6B2200C7C for ; Mon, 5 Jun 2017 19:40:08 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 7D399160BBB; Mon, 5 Jun 2017 17:40:08 +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 C47E9160BD4 for ; Mon, 5 Jun 2017 19:40:07 +0200 (CEST) Received: (qmail 51532 invoked by uid 500); 5 Jun 2017 17:40:06 -0000 Mailing-List: contact dev-help@pig.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@pig.apache.org Delivered-To: mailing list dev@pig.apache.org Received: (qmail 51521 invoked by uid 500); 5 Jun 2017 17:40:06 -0000 Delivered-To: apmail-hadoop-pig-dev@hadoop.apache.org Received: (qmail 51518 invoked by uid 99); 5 Jun 2017 17:40:06 -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; Mon, 05 Jun 2017 17:40:06 +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 7C50DC3177 for ; Mon, 5 Jun 2017 17:40:06 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -99.202 X-Spam-Level: X-Spam-Status: No, score=-99.202 tagged_above=-999 required=6.31 tests=[KAM_ASCII_DIVIDERS=0.8, RP_MATCHES_RCVD=-0.001, SPF_PASS=-0.001, USER_IN_WHITELIST=-100] autolearn=disabled Received: from mx1-lw-us.apache.org ([10.40.0.8]) by localhost (spamd1-us-west.apache.org [10.40.0.7]) (amavisd-new, port 10024) with ESMTP id KZcY5AueLzuV for ; Mon, 5 Jun 2017 17:40:06 +0000 (UTC) Received: from mailrelay1-us-west.apache.org (mailrelay1-us-west.apache.org [209.188.14.139]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTP id BC8AA5FD3F for ; Mon, 5 Jun 2017 17:40:05 +0000 (UTC) Received: from jira-lw-us.apache.org (unknown [207.244.88.139]) by mailrelay1-us-west.apache.org (ASF Mail Server at mailrelay1-us-west.apache.org) with ESMTP id 0C2F3E01A8 for ; Mon, 5 Jun 2017 17:40:05 +0000 (UTC) Received: from jira-lw-us.apache.org (localhost [127.0.0.1]) by jira-lw-us.apache.org (ASF Mail Server at jira-lw-us.apache.org) with ESMTP id 4D72F21B61 for ; Mon, 5 Jun 2017 17:40:04 +0000 (UTC) Date: Mon, 5 Jun 2017 17:40:04 +0000 (UTC) From: "Rohini Palaniswamy (JIRA)" To: pig-dev@hadoop.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Commented] (PIG-4700) Enable progress reporting for Tasks in Tez MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 archived-at: Mon, 05 Jun 2017 17:40:08 -0000 [ https://issues.apache.org/jira/browse/PIG-4700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16037262#comment-16037262 ] Rohini Palaniswamy commented on PIG-4700: ----------------------------------------- bq. Could you make it 1000? i.e schedule it every second Actually it can be optimized better. Progress information is sent as part of task heartbeat. In setups like ours heartbeat interval is set to 3 seconds so that the AM can handle 10s of thousands of tasks. So we should set it to a value slightly lower than heartbeat interval. {code} progressHelper.scheduleProgressTaskService(100, Math.max(1000, (conf.getInt(TezConfiguration.TEZ_TASK_AM_HEARTBEAT_INTERVAL_MS, TezConfiguration.TEZ_TASK_AM_HEARTBEAT_INTERVAL_MS_DEFAULT) - 50))); {code} > Enable progress reporting for Tasks in Tez > ------------------------------------------ > > Key: PIG-4700 > URL: https://issues.apache.org/jira/browse/PIG-4700 > Project: Pig > Issue Type: Bug > Reporter: Rohini Palaniswamy > Assignee: Satish Subhashrao Saley > Fix For: 0.18.0 > > Attachments: PIG-4700-1.patch, PIG-4700-2.patch, PIG-4700-3.patch, PIG-4700-4.patch, PIG-4700-5.patch > > -- This message was sent by Atlassian JIRA (v6.3.15#6346)