From 12db28964f201d70636961c65c841b07a0e52513 Mon Sep 17 00:00:00 2001 From: meek0 Date: Fri, 10 Jan 2025 08:53:55 -0500 Subject: [PATCH] fix: CLIN-2536 glow register for GenomicImplicts.vcf --- .../ferlab/datalake/spark3/implicits/GenomicImplicits.scala | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/datalake-spark3/src/main/scala/bio/ferlab/datalake/spark3/implicits/GenomicImplicits.scala b/datalake-spark3/src/main/scala/bio/ferlab/datalake/spark3/implicits/GenomicImplicits.scala index 4aec8f8e..e16add6e 100644 --- a/datalake-spark3/src/main/scala/bio/ferlab/datalake/spark3/implicits/GenomicImplicits.scala +++ b/datalake-spark3/src/main/scala/bio/ferlab/datalake/spark3/implicits/GenomicImplicits.scala @@ -812,7 +812,8 @@ object GenomicImplicits { def vcf(input: String, referenceGenomePath: Option[String], optional: Boolean, split: Boolean)(implicit spark: SparkSession): DataFrame = { try { val inputs = input.split(",") - val df = spark.read + val sess = Glow.register(spark) + val df = sess.read .format("vcf") .option("flattenInfoFields", "true") .load(inputs: _*)