carbondata-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jackylk <...@git.apache.org>
Subject [GitHub] carbondata pull request #1455: [CARBONDATA-1624]Set the default value of 'ca...
Date Sun, 05 Nov 2017 02:17:02 GMT
Github user jackylk commented on a diff in the pull request:

    https://github.com/apache/carbondata/pull/1455#discussion_r148946384
  
    --- Diff: integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/management/LoadTableCommand.scala
---
    @@ -84,6 +84,10 @@ case class LoadTableCommand(
     
         val carbonProperty: CarbonProperties = CarbonProperties.getInstance()
         carbonProperty.addProperty("zookeeper.enable.lock", "false")
    +    carbonProperty.addProperty(CarbonCommonConstants.NUM_CORES_LOADING,
    +        carbonProperty.getProperty(CarbonCommonConstants.NUM_CORES_LOADING,
    +            Math.min(sparkSession.sparkContext.conf.getInt("spark.executor.cores", 1),
    +                CarbonCommonConstants.NUM_CORES_MAX_VAL).toString()))
    --- End diff --
    
    Instead of using `NUM_CORES_MAX_VAL`
    You can modify `NUM_CORES_DEFAULT_VAL` to 32 directly, so that user does not need to provide
`NUM_CORES_DEFAULT_VAL`


---

Mime
View raw message