Github user wangyum commented on the issue:

    https://github.com/apache/spark/pull/22615
  
    We can simplery this:
    
https://github.com/apache/spark/blob/7ad18ee9f26e75dbe038c6034700f9cd4c0e2baa/resource-managers/yarn/src/main/scala/org/apache/spark/deploy/yarn/Client.scala#L273-L295
    to
    ```scala
        sparkConf.get(ROLLED_LOG_INCLUDE_PATTERN).foreach { includePattern =>
          val logAggregationContext = 
Records.newRecord(classOf[LogAggregationContext])
          logAggregationContext.setRolledLogsIncludePattern(includePattern)
          sparkConf.get(ROLLED_LOG_EXCLUDE_PATTERN).foreach { excludePattern =>
            logAggregationContext.setRolledLogsExcludePattern(excludePattern)
          }
          appContext.setLogAggregationContext(logAggregationContext)
    ```


---

---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to