File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
core/src/main/scala/org/apache/spark/deploy Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -141,7 +141,7 @@ class SparkHadoopUtil extends Logging {
141141 val baselineBytesRead = f()
142142 Some (() => f() - baselineBytesRead)
143143 } catch {
144- case e : NoSuchMethodException => {
144+ case e @ ( _ : NoSuchMethodException | _ : ClassNotFoundException ) => {
145145 logDebug(" Couldn't find method for retrieving thread-level FileSystem input data" , e)
146146 None
147147 }
@@ -163,7 +163,7 @@ class SparkHadoopUtil extends Logging {
163163 val baselineBytesWritten = f()
164164 Some (() => f() - baselineBytesWritten)
165165 } catch {
166- case e : NoSuchMethodException => {
166+ case e @ ( _ : NoSuchMethodException | _ : ClassNotFoundException ) => {
167167 logDebug(" Couldn't find method for retrieving thread-level FileSystem output data" , e)
168168 None
169169 }
You can’t perform that action at this time.
0 commit comments