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 7DA93200BA0 for ; Fri, 30 Sep 2016 07:20:25 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 7C73F160AE4; Fri, 30 Sep 2016 05:20:25 +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 C2B24160AE3 for ; Fri, 30 Sep 2016 07:20:24 +0200 (CEST) Received: (qmail 30309 invoked by uid 500); 30 Sep 2016 05:20:23 -0000 Mailing-List: contact issues-help@carbondata.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@carbondata.incubator.apache.org Delivered-To: mailing list issues@carbondata.incubator.apache.org Received: (qmail 30300 invoked by uid 99); 30 Sep 2016 05:20:23 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd2-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 30 Sep 2016 05:20:23 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd2-us-west.apache.org (ASF Mail Server at spamd2-us-west.apache.org) with ESMTP id 56EB11A5233 for ; Fri, 30 Sep 2016 05:20:23 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd2-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 (spamd2-us-west.apache.org [10.40.0.9]) (amavisd-new, port 10024) with ESMTP id 7qLhNFJG4SJC for ; Fri, 30 Sep 2016 05:20:22 +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 9FA185F253 for ; Fri, 30 Sep 2016 05:20:21 +0000 (UTC) Received: (qmail 30279 invoked by uid 99); 30 Sep 2016 05:20:20 -0000 Received: from arcas.apache.org (HELO arcas) (140.211.11.28) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 30 Sep 2016 05:20:20 +0000 Received: from arcas.apache.org (localhost [127.0.0.1]) by arcas (Postfix) with ESMTP id ADDA82C002D for ; Fri, 30 Sep 2016 05:20:20 +0000 (UTC) Date: Fri, 30 Sep 2016 05:20:20 +0000 (UTC) From: "ASF GitHub Bot (JIRA)" To: issues@carbondata.incubator.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Commented] (CARBONDATA-267) Set block_size for table on table level MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 archived-at: Fri, 30 Sep 2016 05:20:25 -0000 [ https://issues.apache.org/jira/browse/CARBONDATA-267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15535068#comment-15535068 ] ASF GitHub Bot commented on CARBONDATA-267: ------------------------------------------- Github user manishgupta88 commented on a diff in the pull request: https://github.com/apache/incubator-carbondata/pull/189#discussion_r81279628 --- Diff: processing/src/main/java/org/apache/carbondata/processing/store/writer/AbstractFactDataWriter.java --- @@ -196,11 +197,22 @@ public AbstractFactDataWriter(String storeLocation, int measureCount, int mdKeyL blockIndexInfoList = new ArrayList<>(); // get max file size; CarbonProperties propInstance = CarbonProperties.getInstance(); - this.fileSizeInBytes = Long.parseLong(propInstance - .getProperty(CarbonCommonConstants.MAX_FILE_SIZE, - CarbonCommonConstants.MAX_FILE_SIZE_DEFAULT_VAL)) - * CarbonCommonConstants.BYTE_TO_KB_CONVERSION_FACTOR - * CarbonCommonConstants.BYTE_TO_KB_CONVERSION_FACTOR * 1L; + // If blocksize is defined by create table ddl, then use this value otherwise + // use system level property + if (blocksize >= CarbonCommonConstants.MAX_FILE_SIZE_DEFAULT_VAL_MIN_VAL && + blocksize <= CarbonCommonConstants.MAX_FILE_SIZE_DEFAULT_VAL_MAX_VAL) { + LOGGER.audit("The max file size is set in table level. "); + this.fileSizeInBytes = blocksize * CarbonCommonConstants.BYTE_TO_KB_CONVERSION_FACTOR + * CarbonCommonConstants.BYTE_TO_KB_CONVERSION_FACTOR * 1L; + } else { + LOGGER.audit("The max file size in create table ddl is not set or is invalid, " + + "so here use " + CarbonCommonConstants.MAX_FILE_SIZE + "to set. "); --- End diff -- @Zhangshunyu ...I am thinking instead of validating block size here specified by the user, we can validate at the time of creating the table and in error message we can display the range of allowed block size so that user is not confused. If user does not specify the block size the consider the default value and update in the schema > Set block_size for table on table level > --------------------------------------- > > Key: CARBONDATA-267 > URL: https://issues.apache.org/jira/browse/CARBONDATA-267 > Project: CarbonData > Issue Type: New Feature > Affects Versions: 0.1.0-incubating > Reporter: zhangshunyu > Assignee: zhangshunyu > Fix For: 0.2.0-incubating > > > Set block_size for table on table level -- This message was sent by Atlassian JIRA (v6.3.4#6332)