forked from D-Net/dnet-hadoop
NPE fixed
This commit is contained in:
parent
bc835d2024
commit
4a439c3863
|
@ -48,7 +48,7 @@ object SparkResolveRelation {
|
||||||
m =>
|
m =>
|
||||||
val sourceResolved = m._2
|
val sourceResolved = m._2
|
||||||
val currentRelation = m._1._2
|
val currentRelation = m._1._2
|
||||||
if (sourceResolved!=null && sourceResolved._2.nonEmpty)
|
if (sourceResolved!=null && sourceResolved._2!=null && sourceResolved._2.nonEmpty)
|
||||||
currentRelation.setSource(sourceResolved._2)
|
currentRelation.setSource(sourceResolved._2)
|
||||||
currentRelation
|
currentRelation
|
||||||
}.write
|
}.write
|
||||||
|
|
Loading…
Reference in New Issue