From 7af75e5a765be1e1dd58d88b0a76c3022aa605d0 Mon Sep 17 00:00:00 2001 From: Frank Austin Nothaft Date: Wed, 19 Mar 2014 08:25:37 -0700 Subject: [PATCH] Fixing Job.getInstance call that breaks hadoop 1 compatibility. --- .../cs/amplab/adam/rdd/variation/ADAMVariationContext.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/adam-core/src/main/scala/edu/berkeley/cs/amplab/adam/rdd/variation/ADAMVariationContext.scala b/adam-core/src/main/scala/edu/berkeley/cs/amplab/adam/rdd/variation/ADAMVariationContext.scala index 72ef96a7d0..404a65394a 100644 --- a/adam-core/src/main/scala/edu/berkeley/cs/amplab/adam/rdd/variation/ADAMVariationContext.scala +++ b/adam-core/src/main/scala/edu/berkeley/cs/amplab/adam/rdd/variation/ADAMVariationContext.scala @@ -85,7 +85,7 @@ class ADAMVariationContext(sc: SparkContext) extends Serializable with Logging { def adamVCFAnnotationLoad(filePath: String): RDD[ADAMDatabaseVariantAnnotation] = { log.info("Reading VCF file from %s".format(filePath)) - val job = Job.getInstance(sc.hadoopConfiguration) + val job = new Job(sc.hadoopConfiguration) val vcc = new VariantContextConverter val records = sc.newAPIHadoopFile( filePath,