Pipeline Executor Preconfiguration

Static configurations used for different execution engines are set in the dt_executor_configs.yaml configuration file located in the $IW_HOME/conf folder. This file can be edited for pipelines to work with different versions and configurations of Hive or Spark.

Sample dt_executor_configs.yaml File

    
​x
 
#Executor Configurations​---​batchEngine: "SPARK"​udfStatements:​- "DROP FUNCTION IF EXISTS iwrowid"​- "CREATE TEMPORARY FUNCTION iwrowid AS 'io.infoworks.awb.udfs.RowIdUDF'"​- "DROP FUNCTION IF EXISTS iwltrim"​- "CREATE TEMPORARY FUNCTION iwltrim AS 'io.infoworks.awb.udfs.LTrimUDF'"​- "DROP FUNCTION IF EXISTS iwrtrim"​- "CREATE TEMPORARY FUNCTION iwrtrim AS 'io.infoworks.awb.udfs.RTrimUDF'"​- "DROP FUNCTION IF EXISTS iwtrim"​- "CREATE TEMPORARY FUNCTION iwtrim AS 'io.infoworks.awb.udfs.TrimUDF'"​- "DROP FUNCTION IF EXISTS iwuuid"​- "CREATE TEMPORARY FUNCTION iwuuid AS 'io.infoworks.awb.udfs.UuidUDF'"​- "DROP FUNCTION IF EXISTS iwsplit"​- "CREATE TEMPORARY FUNCTION iwsplit AS 'io.infoworks.awb.udfs.SplitUDF'"​- "DROP FUNCTION IF EXISTS iwdateloop"​- "CREATE TEMPORARY FUNCTION iwdateloop AS 'io.infoworks.awb.udfs.LoopUDF'"​- "DROP FUNCTION IF EXISTS iwgenrows"​- "CREATE TEMPORARY FUNCTION iwgenrows AS 'io.infoworks.awb.udfs.GenRowsUDF'"​- "DROP FUNCTION IF EXISTS iwtime_similarity"​- "CREATE TEMPORARY FUNCTION iwtime_similarity AS 'io.infoworks.awb.udfs.TimeSimilarityUDF'"​- "DROP FUNCTION IF EXISTS SeqId"​- "CREATE TEMPORARY FUNCTION SeqId AS 'io.infoworks.awb.udfs.SeqIdUDF'"​propertyStatements:​partitionedTargetProperties:​- "SET hive.exec.dynamic.partition = true"​- "SET hive.exec.dynamic.partition.mode = nonstrict "​- "SET hive.optimize.sort.dynamic.partition=true"​---​batchEngine: "HIVE"​udfStatements:​- "ADD JAR ${iw_hdfs_udfs_path}/df-shared.jar"​- "DROP FUNCTION IF EXISTS iwrowid"​- "CREATE TEMPORARY FUNCTION iwrowid AS 'io.infoworks.awb.udfs.RowIdUDF'"​- "DROP FUNCTION IF EXISTS iwltrim"​- "CREATE TEMPORARY FUNCTION iwltrim AS 'io.infoworks.awb.udfs.LTrimUDF'"​- "DROP FUNCTION IF EXISTS iwrtrim"​- "CREATE TEMPORARY FUNCTION iwrtrim AS 'io.infoworks.awb.udfs.RTrimUDF'"​- "DROP FUNCTION IF EXISTS iwtrim"​- "CREATE TEMPORARY FUNCTION iwtrim AS 'io.infoworks.awb.udfs.TrimUDF'"​- "DROP FUNCTION IF EXISTS iwuuid"​- "CREATE TEMPORARY FUNCTION iwuuid AS 'io.infoworks.awb.udfs.UuidUDF'"​- "DROP FUNCTION IF EXISTS iwsplit"​- "CREATE TEMPORARY FUNCTION iwsplit AS 'io.infoworks.awb.udfs.SplitUDF'"​- "DROP FUNCTION IF EXISTS iwdateloop"​- "CREATE TEMPORARY FUNCTION iwdateloop AS 'io.infoworks.awb.udfs.LoopUDF'"​- "DROP FUNCTION IF EXISTS iwgenrows"​- "CREATE TEMPORARY FUNCTION iwgenrows AS 'io.infoworks.awb.udfs.GenRowsUDF'"​- "DROP FUNCTION IF EXISTS iwtime_similarity"​- "CREATE TEMPORARY FUNCTION iwtime_similarity AS 'io.infoworks.awb.udfs.TimeSimilarityUDF'"​- "DROP FUNCTION IF EXISTS SeqId"​- "CREATE TEMPORARY FUNCTION SeqId AS 'io.infoworks.awb.udfs.SeqIdUDF'"​propertyStatements:​commonProperties:​- "SET hive.enforce.bucketing=true"​- "SET hive.optimize.bucketingsorting=false"​partitionedTargetProperties:​- "SET hive.exec.dynamic.partition=true"​- "SET hive.exec.dynamic.partition.mode=nonstrict"​- "SET hive.optimize.sort.dynamic.partition=true"
Copy

For troubleshooting, see Troubleshooting YAML Executor Configuration.

Last updated on

Was this page helpful?