fix

Author: annie-mac

sdk/cosmos/azure-cosmos-spark_3-4_2-12/src/main/scala/com/azure/cosmos/spark/SparkInternalsBridge.scala

@@ -80,7 +80,7 @@ object SparkInternalsBridge extends BasicLoggingTrait {
     }
   }
 
-  private def getInternalCustomTaskMetricsAsSQLMetricInternal(
+  private def ConsistencygetInternalCustomTaskMetricsAsSQLMetricInternal(
                                                                knownCosmosMetricNames: Set[String],
                                                                taskMetrics: TaskMetrics): Map[String, SQLMetric] = {
     getAccumulators(taskMetrics) match {

sdk/cosmos/azure-cosmos-spark_3_2-12/src/main/scala/com/azure/cosmos/spark/PartitionMetadata.scala

@@ -132,8 +132,9 @@ private[cosmos] case class PartitionMetadata
   }
 
   def getAvgChangesPerLsn: Double = {
-    val effectiveFirstLsn = if (this.firstLsn.isEmpty) 0 else this.firstLsn.get
-    if (this.documentCount == 0 || (this.getAndValidateLatestLsn - effectiveFirstLsn) <= 0) {
+    if (this.firstLsn.isEmpty) {
+      math.max(1d, this.documentCount.toDouble / this.getAndValidateLatestLsn)
+    } else if (this.documentCount == 0 || (this.getAndValidateLatestLsn - this.firstLsn.get) <= 0) {
       1d
     } else {
       this.documentCount.toDouble / (this.getAndValidateLatestLsn- this.firstLsn.get)