From 08ff48ffa677d2b90827e025d216b21dcd4b24bd Mon Sep 17 00:00:00 2001 From: Emilio Lahr-Vivaz Date: Mon, 11 Mar 2024 17:57:36 +0000 Subject: [PATCH] GEOMESA-3333 Fix StatsCombiner for cross-version compatibility --- .../geomesa/accumulo/combiners/StatsCombiner.scala | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/geomesa-accumulo/geomesa-accumulo-iterators/src/main/scala/org/locationtech/geomesa/accumulo/combiners/StatsCombiner.scala b/geomesa-accumulo/geomesa-accumulo-iterators/src/main/scala/org/locationtech/geomesa/accumulo/combiners/StatsCombiner.scala index 184b18ca91b4..39a8193e2354 100644 --- a/geomesa-accumulo/geomesa-accumulo-iterators/src/main/scala/org/locationtech/geomesa/accumulo/combiners/StatsCombiner.scala +++ b/geomesa-accumulo/geomesa-accumulo-iterators/src/main/scala/org/locationtech/geomesa/accumulo/combiners/StatsCombiner.scala @@ -144,7 +144,8 @@ object StatsCombiner { private def attach(connector: AccumuloClient, table: String, options: Map[String, String]): Unit = { // priority needs to be less than the versioning iterator at 20 - val is = new IteratorSetting(10, CombinerName, classOf[StatsCombiner]) + // note: we use the old class name to allow full interop between gm versions + val is = new IteratorSetting(10, CombinerName, "org.locationtech.geomesa.accumulo.data.stats.StatsCombiner") options.foreach { case (k, v) => is.addOption(k, v) } connector.tableOperations().attachIterator(table, is) }