- Configure Spark properties for Spark Worker daemon @ Unravel
Configure Spark properties for Spark Worker daemon @ Unravel
Property/Description | Set By User | Unit | Default |
|---|---|---|---|
com.unraveldata.spark.live.pipeline.enabled Specifies if Unravel should process the live job data coming from sensor or not. true: The live job data will be processed as soon as it is received. false: Live job data will not be processed. | boolean | true | |
com.unraveldata.spark.live.pipeline.maxStoredStages Maximum number of jobs/stages stored in the DB. If an application has This setting affects only the live pipeline. When processing the event log file (after the application has completed its execution) this property is not considered. | count | 1000 | |
com.unraveldata.spark.master Default spark master mode to be used if not available from Sensor. Possible values: local, standalone or yarn (default) | set member | yarn |
Property/Description | Set By User | Unit | Default |
|---|---|---|---|
com.unraveldata.spark.eventlog.location All the possible locations of the event log files. Multiple locations are supported as a comma separated list of values. This property is used only when the Unravel sensor is not enabled. When the sensor is enabled, the event log path is taken from the application configuration at runtime. | string |
| |
com.unraveldata.spark.eventlog.maxSize Maximum size of the event log file that will be processed by the Spark worker daemon. Event logs larger than | bytes | 1000000000 (~1GB) | |
com.unraveldata.spark.eventlog.appDuration.mins Maximum duration (in minutes) of application to pull Spark event log. | min | 1440 (1 day) | |
com.unraveldata.spark.hadoopFsMulti.useFilteredFiles Specifies how to search the event log files. true: prefix search false: prefix + suffix search Prefix + suffix search is faster as it avoids listFiles() API which may take a long time for large directories on HDFS. This search requires that all the possible suffixes for the event log files are known. Possible suffixes are specified by com.unraveldata.spark.hadoopFsMulti.eventlog.suffixes.. | boolean | false | |
com.unraveldata.spark.hadoopFsMulti.eventlog.suffixes Specifies suffixes used for prefix+suffix search of the event logs when com.unraveldata.spark.hadoopFsMulti.useFilteredFiles=false. NOTE: the empty suffix (,,) be part of this value for uncompressed event log files. | CSL | ,,.lz4,.snappy,.inprogres | |
com.unraveldata.spark.appLoading.maxAttempts Maximum number of attempts for loading the event log file from HDFS/S3/ ADL/WASB etc. | count | 3 | |
com.unraveldata.spark.appLoading.delayForRetry Delay used among consecutive retries when loading the event log files. The actual delay is not constant, it increases progressively by 2^attempt * delayForRetry. | ms | 2000 (2 s) | |
com.unraveldata.spark.tasks.inMemoryLimit Number of tasks to be kept in memory and DB per stage. All stats are calculated for all the task attempts but only the configured number of tasks will be kept in memory/DB. | count | 1000 | |
Events Related | |||
com.unraveldata.spark.events.enableCaching Enables logic for executing caching events. | boolean | false | |
Property/Description | Set By User | Unit | Default |
|---|---|---|---|
com.unraveldata.spark.appLoading.maxConcurrentApps This is the number of applications for which to keep metadata in Spark worker daemon memory. | count | 5 | |
ccom.unraveldata.spark.time.histogram Specifies whether the timeline histogram is generated or not. Note: Timeline histogram generation is memory intensive. | boolean | false |
spark-default.confProperty/Description | Set By User | Unit | Default |
|---|---|---|---|
com.unraveldata.spark.shutdown.delay.ms Amount of time to delay shutdown so the last messages are processed (allows Btrace sensor to send all the data before the spark driver exits). | ms | 0 | |
com.unraveldata.spark.live.interval.sec This is the interval in seconds after which live application data is updated. It allows for tracking of Spark tasks. The Spark APM updates on Task completion in addition Job start, and Job and Stage completion. | s | 60 |
Name/Description | Set By User | Unit | Default |
|---|---|---|---|
com.unraveldata.job.collector.running.load.conf When set to true
| boolean | false | |
com.unraveldata.job.collector.hive.queries.cache.size This is used to improve the Hive-MR pipeline by caching data so it can be retrieved from cache instead of external API. You should not have to change this value. | count | 1000 | |
com.unraveldata.max.attempt.log.dir.size.in.bytes Maximum size of the aggregated executor log that are imported and processed by the Spark worker for a successful application. | byte | 500000000 (~500 MB) | |
com.unraveldata.max.failed.attempt.log.dir.size.in.bytes Maximum size of the aggregated executor log that are imported and processed by the Spark worker for a failed application. | byte | 2000000000 (~2 GB) | |
com.unraveldata.min.job.duration.for.attempt.log Minimum duration of a successful application or which executor logs are processed (in milliseconds). | ms | 600000 (10 mins) | |
com.unraveldata.min.failed.job.duration.for.attempt.log Minimum duration of failed/killed application for which executor logs are processed (in milliseconds). | ms | 60000 | |
com.unraveldata.attempt.log.max.containers Maximum number of containers for the application. If application has more that configured number of containers then the aggregated executor log isprocessed for the application. | ms | 500 | |
com.unraveldata.spark.master Default master for spark applications. (Used to download executor log using correct APIs.) Valid Options: yarn, mesos, standalone. | string | yarn |
Property/Description | Set By user | Unit | Default |
com.unraveldata.s3.profile.config.file.path The path to the s3 profile file, e.g., | string | - | |
com.unraveldata.spark.s3.profilesToBuckets Comma separated list of profile to bucket mappings in the following format: <s3_profile>:<s3_bucket>, i.e., com.unraveldata.spark.s3.profileToBuckets=profile-prod:com.unraveldata.dev,profile-dev:com.unraveldata.dev. Note ImportantEnsure that the profiles defined in the property above are actually present in the s3 properties file and that each profile has associated a corresponding pair of credentials | CSL | - |
Property/Description | Set By User | Unit | Default |
|---|---|---|---|
com.unraveldata.tagging.enabled Enables tagging functionality. | boolean | true | |
com.unraveldata.tagging.script.enabled Enables tagging. | boolean | false | |
com.unraveldata.app.tagging.script.path Specifies tagging script path to use when enabled=true. | string (path) | /usr/local/unravel/etc/apptag.py | |
com.unraveldata.app.tagging.script.method.name The name of the method in the python script that generates the tagging dictionary. | string | generate_unravel_tags |
Property/Description | Set By User | Unit | Default |
|---|---|---|---|
com.unraveldata.hdinsight.storage-account. Storage account name that a HDInsight cluster uses. You must define this property for each storage account. X starts with 1 and then is incremented by 1 for each additional account. The account numbers must be consecutive | Optional | string | - |
com.unraveldata.hdinsight.access-key. Storage account key. For each storage account storage-account. | Optional | string | - |
For example, for three storage accounts you would define three (3) pairs of <storage name, storage access key>.
com.unraveldata.hdinsight.storage-account.1=Storage1 com.unraveldata.hdinsight.access-key.1=Storage1AccessKey com.unraveldata.hdinsight.storage-account.2=Storage2 com.unraveldata.hdinsight.access-key.2=Storage2AccessKey com.unraveldata.hdinsight.storage-account.3=Storage3 com.unraveldata.hdinsight.access-key.3=Storage3AccessKey
Property/Description | Set By User | Unit | Default |
|---|---|---|---|
com.unraveldata.adl.accountFQDN The data lake's fully qualified domain name, e.g., mydatalake.azuredatalakestore.net. | Optional | string | - |
com.unraveldata.adl.clientId An application ID. An application registration has to be created in the Azure Active Directory. | Optional | string | - |
com.unraveldata.adl.clientKey An application access key which can be created after registering an application. | Optional | string | - |
com.unraveldata.adl.accessTokenEndpoint The OAUTH 2.0 Access Token Endpoint. It is obtained from the application registration tab on Azure portal. | Optional | string | - |
com.unraveldata.adl.clientRootPath The path in the Data lake store where the target cluster has been given access. | Optional | string URL | - |