adding jsonignore filter back

streamnative · Nov 7, 2024 · 0d49797 · 0d49797
1 parent 2af4c6e
commit 0d49797
Showing 1 changed file with 3 additions and 5 deletions.
diff --git a/src/main/scala/org/apache/spark/sql/pulsar/PulsarConfigurationUtils.scala b/src/main/scala/org/apache/spark/sql/pulsar/PulsarConfigurationUtils.scala
@@ -18,17 +18,15 @@ import java.util.Locale
 
 import scala.reflect._
 
-import org.apache.pulsar.client.impl.conf.{
-  ClientConfigurationData,
-  ProducerConfigurationData,
-  ReaderConfigurationData
-}
+import com.fasterxml.jackson.annotation.JsonIgnore
+import org.apache.pulsar.client.impl.conf.{ClientConfigurationData, ProducerConfigurationData, ReaderConfigurationData}
 
 object PulsarConfigurationUtils {
 
   private def nonIgnoredFields[T: ClassTag] = {
     classTag[T].runtimeClass.getDeclaredFields
       .filter(f => !Modifier.isStatic(f.getModifiers))
+      .filter(f => f.getDeclaredAnnotation(classOf[JsonIgnore]) == null)
       .map(_.getName)
   }