improve logging (#153)

* improve logging * improve logging
streamnative · Aug 24, 2023 · 67d5c58 · 67d5c58
1 parent a07d445
commit 67d5c58
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/scala/org/apache/spark/sql/pulsar/PulsarSources.scala b/src/main/scala/org/apache/spark/sql/pulsar/PulsarSources.scala
@@ -172,7 +172,7 @@ class PulsarSourceInitialOffsetWriter(sparkSession: SparkSession, metadataPath:
   }
 }
 
-private[pulsar] class PulsarOffsetRange private (
+private[pulsar] case class PulsarOffsetRange private (
     private var topic_ : String,
     private var fromOffset_ : MessageId,
     private var untilOffset_ : MessageId,