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 8169E200BB4 for ; Tue, 1 Nov 2016 18:45:04 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id 7FEA8160AF7; Tue, 1 Nov 2016 17:45:04 +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 C82DC160ADA for ; Tue, 1 Nov 2016 18:45:03 +0100 (CET) Received: (qmail 82429 invoked by uid 500); 1 Nov 2016 17:45:02 -0000 Mailing-List: contact dev-help@apex.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@apex.apache.org Delivered-To: mailing list dev@apex.apache.org Received: (qmail 82418 invoked by uid 99); 1 Nov 2016 17:45:02 -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; Tue, 01 Nov 2016 17:45:02 +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 70606C0C04 for ; Tue, 1 Nov 2016 17:45:02 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-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 (spamd4-us-west.apache.org [10.40.0.11]) (amavisd-new, port 10024) with ESMTP id R9Y8jlgpUXHo for ; Tue, 1 Nov 2016 17:45:01 +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 E74655FC7B for ; Tue, 1 Nov 2016 17:45:00 +0000 (UTC) Received: (qmail 80836 invoked by uid 99); 1 Nov 2016 17:45:00 -0000 Received: from arcas.apache.org (HELO arcas) (140.211.11.28) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 01 Nov 2016 17:45:00 +0000 Received: from arcas.apache.org (localhost [127.0.0.1]) by arcas (Postfix) with ESMTP id 0B1AF2C0D55 for ; Tue, 1 Nov 2016 17:45:00 +0000 (UTC) Date: Tue, 1 Nov 2016 17:45:00 +0000 (UTC) From: "Chandni Singh (JIRA)" To: dev@apex.incubator.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Commented] (APEXMALHAR-2321) Improve Buckets memory management MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 archived-at: Tue, 01 Nov 2016 17:45:04 -0000 [ https://issues.apache.org/jira/browse/APEXMALHAR-2321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15626117#comment-15626117 ] Chandni Singh commented on APEXMALHAR-2321: ------------------------------------------- >>AbstractManagedStateImpl.maxMemorySize probably will be misunderstand as the max memory size of total managed state, but in fact it was used as memory size of each bucket. Better to rename it. This is incorrect. This setting is not used per bucket. Please look at lines 94-98 in StateTracker. Bytes are summed over all buckets and then compared to maxMemorySize. > Improve Buckets memory management > --------------------------------- > > Key: APEXMALHAR-2321 > URL: https://issues.apache.org/jira/browse/APEXMALHAR-2321 > Project: Apache Apex Malhar > Issue Type: Improvement > Reporter: bright chen > Assignee: bright chen > > Currently buckets were managed as an array. Each bucket have memory limitation, and free memory will be triggered if the bucket memory usage over the limitation. > - For ManagedTimeUnifiedStateImpl, the default bucket number is 345600, which probably too large. > - AbstractManagedStateImpl.maxMemorySize probably will be misunderstand as the max memory size of total managed state, but in fact it was used as memory size of each bucket. Better to rename it. > - The default maxMemorySize is zero. It's better to give a default reasonable value to avoid too much garbage collection -- This message was sent by Atlassian JIRA (v6.3.4#6332)