GitHub user xuchuanyin opened a pull request:
https://github.com/apache/carbondata/pull/1808 [CARBONDATA-2023][DataLoad] Add size base block allocation in data loading Carbondata assign blocks to nodes at the beginning of data loading. Previous block allocation strategy is block number based and it will shuffer skewed data problem if the size of input files differs a lot. We introduced a size based block allocation strategy to optimize data loading performance in skewed data scenario. Be sure to do all of the following checklist to help us incorporate your contribution quickly and easily: - [x] Any interfaces changed? `Only changed the internal interfaces` - [x] Any backward compatibility impacted? `No` - [x] Document update required? `Updated the document` - [x] Testing done Please provide details on - Whether new unit test cases have been added or why no new tests are required? `Added tests to verify the block-allocation correctness` - How it is tested? Please attach test report. `Tested in local 3-node cluster` - Is it a performance related change? Please attach the performance test report. ``` In my scenario, the size of input data file varies from 1KB to about 5GB. Before enabling this feature, each executor processed the same number of blocks and the processed data size had a 5X gap. --(block number based allocation) After enabling this feature, each executor processed almost the same size of data and the processed data blocks had 6X gap. -- (block size based allocation) The data loading performance had been promoted from 41MB/s/Node to 61MB/s/Node, about 50% performance enhancement gained. ``` - Any additional information to help reviewers in testing this change. `I refactored the code to make it more readable. The core code mainly lies in CarbonLoaderUtil` - [x] For large changes, please consider breaking it into sub-tasks under an umbrella JIRA. `Not related` You can merge this pull request into a Git repository by running: $ git pull https://github.com/xuchuanyin/carbondata opt_size_base_block_allocation Alternatively you can review and apply these changes as the patch at: https://github.com/apache/carbondata/pull/1808.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 #1808 ---- commit f9ee9eaa1d0289c958a0dcbc665a383ea190a812 Author: xuchuanyin <xuchuanyin@...> Date: 2018-01-16T02:59:37Z Add size base block allocation in data loading Carbondata assign blocks to nodes at the beginning of data loading. Previous block allocation strategy is block number based and it will shuffer skewed data problem if the size of input files differs a lot. We introduced a size based block allocation strategy to optimize data loading performance in skewed data scenario. ---- --- |
Github user ravipesala commented on the issue:
https://github.com/apache/carbondata/pull/1808 SDV Build Success , Please check CI http://144.76.159.231:8080/job/ApacheSDVTests/2901/ --- |
In reply to this post by qiuchenjian-2
Github user CarbonDataQA commented on the issue:
https://github.com/apache/carbondata/pull/1808 Build Success with Spark 2.2.1, Please check CI http://88.99.58.216:8080/job/ApacheCarbonPRBuilder/1575/ --- |
In reply to this post by qiuchenjian-2
Github user CarbonDataQA commented on the issue:
https://github.com/apache/carbondata/pull/1808 Build Failed with Spark 2.1.0, Please check CI http://136.243.101.176:8080/job/ApacheCarbonPRBuilder1/2811/ --- |
In reply to this post by qiuchenjian-2
Github user xuchuanyin commented on the issue:
https://github.com/apache/carbondata/pull/1808 retest this please --- |
In reply to this post by qiuchenjian-2
Github user CarbonDataQA commented on the issue:
https://github.com/apache/carbondata/pull/1808 Build Success with Spark 2.2.1, Please check CI http://88.99.58.216:8080/job/ApacheCarbonPRBuilder/1581/ --- |
In reply to this post by qiuchenjian-2
Github user CarbonDataQA commented on the issue:
https://github.com/apache/carbondata/pull/1808 Build Failed with Spark 2.1.0, Please check CI http://136.243.101.176:8080/job/ApacheCarbonPRBuilder1/2816/ --- |
In reply to this post by qiuchenjian-2
Github user xuchuanyin commented on the issue:
https://github.com/apache/carbondata/pull/1808 retest this please --- |
In reply to this post by qiuchenjian-2
Github user CarbonDataQA commented on the issue:
https://github.com/apache/carbondata/pull/1808 Build Failed with Spark 2.2.1, Please check CI http://88.99.58.216:8080/job/ApacheCarbonPRBuilder/1588/ --- |
In reply to this post by qiuchenjian-2
Github user CarbonDataQA commented on the issue:
https://github.com/apache/carbondata/pull/1808 Build Failed with Spark 2.1.0, Please check CI http://136.243.101.176:8080/job/ApacheCarbonPRBuilder1/2824/ --- |
In reply to this post by qiuchenjian-2
Github user ravipesala commented on the issue:
https://github.com/apache/carbondata/pull/1808 SDV Build Success , Please check CI http://144.76.159.231:8080/job/ApacheSDVTests/2909/ --- |
In reply to this post by qiuchenjian-2
Github user ravipesala commented on the issue:
https://github.com/apache/carbondata/pull/1808 SDV Build Success , Please check CI http://144.76.159.231:8080/job/ApacheSDVTests/2911/ --- |
In reply to this post by qiuchenjian-2
Github user CarbonDataQA commented on the issue:
https://github.com/apache/carbondata/pull/1808 Build Success with Spark 2.1.0, Please check CI http://136.243.101.176:8080/job/ApacheCarbonPRBuilder1/2849/ --- |
In reply to this post by qiuchenjian-2
Github user CarbonDataQA commented on the issue:
https://github.com/apache/carbondata/pull/1808 Build Success with Spark 2.2.1, Please check CI http://88.99.58.216:8080/job/ApacheCarbonPRBuilder/1620/ --- |
In reply to this post by qiuchenjian-2
Github user ravipesala commented on the issue:
https://github.com/apache/carbondata/pull/1808 SDV Build Success , Please check CI http://144.76.159.231:8080/job/ApacheSDVTests/2935/ --- |
In reply to this post by qiuchenjian-2
Github user xuchuanyin commented on the issue:
https://github.com/apache/carbondata/pull/1808 retest this please --- |
In reply to this post by qiuchenjian-2
Github user CarbonDataQA commented on the issue:
https://github.com/apache/carbondata/pull/1808 Build Success with Spark 2.2.1, Please check CI http://88.99.58.216:8080/job/ApacheCarbonPRBuilder/1629/ --- |
In reply to this post by qiuchenjian-2
Github user CarbonDataQA commented on the issue:
https://github.com/apache/carbondata/pull/1808 Build Failed with Spark 2.1.0, Please check CI http://136.243.101.176:8080/job/ApacheCarbonPRBuilder1/2862/ --- |
In reply to this post by qiuchenjian-2
Github user ravipesala commented on the issue:
https://github.com/apache/carbondata/pull/1808 SDV Build Fail , Please check CI http://144.76.159.231:8080/job/ApacheSDVTests/2944/ --- |
In reply to this post by qiuchenjian-2
Github user ravipesala commented on the issue:
https://github.com/apache/carbondata/pull/1808 SDV Build Success , Please check CI http://144.76.159.231:8080/job/ApacheSDVTests/2945/ --- |
Free forum by Nabble | Edit this page |