diff --git a/spark/src/main/scala/io/substrait/spark/logical/ToSubstraitRel.scala b/spark/src/main/scala/io/substrait/spark/logical/ToSubstraitRel.scala index a69a1f7c..25ed3402 100644 --- a/spark/src/main/scala/io/substrait/spark/logical/ToSubstraitRel.scala +++ b/spark/src/main/scala/io/substrait/spark/logical/ToSubstraitRel.scala @@ -217,7 +217,7 @@ class ToSubstraitRel extends AbstractLogicalPlanVisitor with Logging { builder.count(limit) } - builder.build() + builder.build() } override def visitGlobalLimit(p: GlobalLimit): relation.Rel = { diff --git a/spark/src/test/scala/io/substrait/spark/SubstraitPlanTestBase.scala b/spark/src/test/scala/io/substrait/spark/SubstraitPlanTestBase.scala index dea8f3a5..0571ee54 100644 --- a/spark/src/test/scala/io/substrait/spark/SubstraitPlanTestBase.scala +++ b/spark/src/test/scala/io/substrait/spark/SubstraitPlanTestBase.scala @@ -95,7 +95,8 @@ trait SubstraitPlanTestBase { self: SharedSparkSession => val extensionCollector = new ExtensionCollector; val proto = new RelProtoConverter(extensionCollector).toProto(pojoRel) - val pojoFromProto = new ProtoRelConverter(extensionCollector, SparkExtension.COLLECTION).from(proto) + val pojoFromProto = + new ProtoRelConverter(extensionCollector, SparkExtension.COLLECTION).from(proto) assertResult(pojoRel)(pojoFromProto) pojoRel2.shouldEqualPlainly(pojoRel)