Compartir a través de

在 Azure HDInsight 中通过 Apache Ambari 优化 Apache Pig

  • Artículo

Apache Ambari 是用于管理和监视 HDInsight 群集的 Web 界面。 有关 Ambari Web UI 的简介，请参阅使用 Apache Ambari Web UI 管理 HDInsight 群集。

可以通过 Ambari Web UI 修改 Apache Pig 属性以优化 Pig 查询。 通过 Ambari 修改 Pig 属性会直接修改 /etc/pig/2.4.2.0-258.0/pig.properties 文件中的 Pig 属性。

  1. 若要修改 Pig 属性，请导航到 Pig 的“配置”选项卡，然后展开“高级 pig-properties”窗格。

  2. 查找、取消注释并更改相应的属性值。

  3. 选择窗口右上方的“保存”以保存新值。 某些属性可能需要重启服务才能生效。

    高级 Apache Pig 属性。

注意

任何会话级设置都会重写 pig.properties 文件中的属性值。

优化执行引擎

可以使用两个执行引擎来执行 Pig 脚本：MapReduce 和 Tez。 Tez 是经过优化的引擎，比 MapReduce 要快得多。

  1. 若要修改执行引擎，请在“高级 pig-properties”窗格中找到 exectype 属性。

  2. 默认值为 MapReduce。 请将它更改为 Tez。

启用本地模式

与在 Hive 中一样，本地模式可用于加快作业，且生成的数据量相对较小。

  1. 若要启用本地模式，请将 pig.auto.local.enabled 设置为 true。 默认值为 false。

  2. 输入数据大小小于 pig.auto.local.input.maxbytes 属性值的作业被视为小型作业。 默认值为 1 GB。

将用户 jar 复制到缓存中

Pig 可将 UDF 所需的 JAR 文件复制到分布式缓存，使这些文件可供任务节点使用。 这些 jar 不经常更改。 如果已启用，pig.user.cache.enabled 设置允许将 jar 放入缓存，使同一用户运行的作业能够重复使用这些文件。 该设置可以小幅提高作业的性能。

  1. 若要启用，请将 pig.user.cache.enabled 设置为 true。 默认值为 false。

  2. 若要设置缓存 jar 的基本路径，请将 pig.user.cache.location 设置为基本路径。 默认为 /tmp。

使用内存设置优化性能

以下内存设置可以帮助优化 Pig 脚本的性能。

  • pig.cachedbag.memusage：给定到包的内存量。 包是元组的集合。 元组是字段的有序集，字段是数据片段。 如果包中的数据超过给定的内存，则会溢出到磁盘。 默认值为 0.2，表示可用内存的 20%。 这是在应用程序中的所有包之间分摊的内存量。

  • pig.spill.size.threshold：超过此溢出大小阈值（以字节为单位）的包将溢出到磁盘。 默认值为 5 MB。

压缩临时文件

Pig 在作业执行期间生成临时文件。 压缩临时文件可以在将文件读取或写入到磁盘时提高性能。 以下设置可用于压缩临时文件。

  • pig.tmpfilecompression：如果为 true，则启用临时文件压缩。 默认值为 false。

  • pig.tmpfilecompression.codec：用于压缩临时文件的压缩编解码器。 建议的压缩编解码器为 LZO 和 Snappy，它们可以降低 CPU 使用率。

启用拆分合并

如果已启用，则会合并小型文件，以减少映射任务数目。 该设置可以提高包含大量小型文件的作业的效率。 若要启用，请将 pig.noSplitCombination 设置为 true。 默认值为 false。

优化映射器

可以通过修改 pig.maxCombinedSplitSize 属性来控制映射器数目。 此属性指定单个映射任务要处理的数据大小。 默认值为文件系统的默认块大小。 增大此值可减少映射器任务的数目。

优化化简器

化简器数目根据 pig.exec.reducers.bytes.per.reducer 参数计算。 该参数指定每个化简器处理的字节数，默认值为 1 GB。 若要限制化简器的最大数目，请设置 pig.exec.reducers.max 属性，默认值为 999。

后续步骤