Fixes deserialization of offsets generated with early versions of the…

… connector (#27455)
Azure · Mar 4, 2022 · 236dd53 · 236dd53
1 parent c4060a2
commit 236dd53
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...os/azure-cosmos-spark_3_2-12/src/main/scala/com/azure/cosmos/spark/ChangeFeedOffset.scala b/...os/azure-cosmos-spark_3_2-12/src/main/scala/com/azure/cosmos/spark/ChangeFeedOffset.scala
@@ -39,6 +39,7 @@ private[spark] object ChangeFeedOffset {
   private val StatePropertyName: String = "state"
   private val InputPartitionsPropertyName: String = "partitions"
   val V1Identifier: String = "spark.cosmos.changeFeed.offset.v1"
+  val V1AlternateIdentifier: String = "azure_cosmos_spark.com.azure.cosmos.spark.changeFeed.offset.v1"
   private val objectMapper = new ObjectMapper()
 
   def fromJson(json: String): ChangeFeedOffset = {
@@ -71,7 +72,8 @@ private[spark] object ChangeFeedOffset {
     parsedNode != null &&
       parsedNode.isObject &&
       parsedNode.get(IdPropertyName) != null &&
-      parsedNode.get(IdPropertyName).asText("") == V1Identifier &&
+      (parsedNode.get(IdPropertyName).asText("") == V1Identifier ||
+        parsedNode.get(IdPropertyName).asText("") == V1AlternateIdentifier) &&
       parsedNode.get(StatePropertyName) != null &&
       parsedNode.get(StatePropertyName).isTextual &&
       parsedNode.get(StatePropertyName).asText("") != ""