Skip to content

Commit

Permalink
Update ucx profiling test to new api (#2851)
Browse files Browse the repository at this point in the history
Signed-off-by: Thomas Graves <tgraves@nvidia.com>
  • Loading branch information
tgravescs authored Jun 30, 2021
1 parent 95b29b0 commit 65892a1
Showing 1 changed file with 2 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -363,7 +363,8 @@ class ApplicationInfoSuite extends FunSuite with Logging {
val eventlogPaths = appArgs.eventlog()
for (path <- eventlogPaths) {
apps += new ApplicationInfo(appArgs.numOutputRows.getOrElse(1000), sparkSession,
EventLogPathProcessor.getEventLogInfo(path, sparkSession).head._1, index)
EventLogPathProcessor.getEventLogInfo(path,
sparkSession.sparkContext.hadoopConfiguration).head._1, index)
index += 1
}
assert(apps.size == 1)
Expand Down

0 comments on commit 65892a1

Please sign in to comment.