Skip to content

Commit

Permalink
3.0.3 deploy test apache#1
Browse files Browse the repository at this point in the history
  • Loading branch information
cjun5 committed Jul 6, 2022
1 parent e994a2a commit 7a21f5a
Showing 1 changed file with 0 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -296,16 +296,13 @@ private[spark] class Client(
try {
val logAggregationContext = Records.newRecord(classOf[LogAggregationContext])

//logAggregationContext.setRolledLogsIncludePattern(includePattern)

// These two methods were added in Hadoop 2.6.4, so we still need to use reflection to
// avoid compile error when building against Hadoop 2.6.0 ~ 2.6.3.
val setRolledLogsIncludePatternMethod =
logAggregationContext.getClass.getMethod("setRolledLogsIncludePattern", classOf[String])
setRolledLogsIncludePatternMethod.invoke(logAggregationContext, includePattern)

sparkConf.get(ROLLED_LOG_EXCLUDE_PATTERN).foreach { excludePattern =>
//logAggregationContext.setRolledLogsExcludePattern(excludePattern)
val setRolledLogsExcludePatternMethod =
logAggregationContext.getClass.getMethod("setRolledLogsExcludePattern", classOf[String])
setRolledLogsExcludePatternMethod.invoke(logAggregationContext, excludePattern)
Expand Down

0 comments on commit 7a21f5a

Please sign in to comment.