Как исправить com.fasterxml.jackson.databind.exc.UnrecognizedPropertyException: нераспознанное поле «sizeMapDefined» - PullRequest
0 голосов
/ 20 декабря 2018

Мы новичок в скале и апаче флинк.Когда мы пытаемся преобразовать scala.collection.mutable.Map в класс Scala POJO, используя ObjectMapper [com.fasterxml.jackson.databind.ObjectMapper], получая нераспознанное поле «sizeMapDefined», исключение.

com.fasterxml.jackson.databind.exc.UnrecognizedPropertyException: нераспознанное поле «sizeMapDefined» (класс com.test.model.Data), не помеченное как игнорируемое

Попытка подписать данныеот AMPS (crankuptheamps) как DataStream с помощью apache flink.

import com.fasterxml.jackson.annotation.JsonIgnoreProperties
import scala.beans.BeanProperty

@JsonIgnoreProperties(ignoreUnknown = true)
@SerialVersionUID(123L)
class Data() extends Serializable {

  @BeanProperty var name: String = _
  @BeanProperty var address: String = _

  override def toString = s"Data($name, $address)"
}

@transient lazy val mapper = new ObjectMapper() with Serializable with ScalaObjectMapper
mapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false)
mapper.registerModule(DefaultScalaModule)




var map = scala.collection.mutable.Map("name" -> "Thiru",
            "address" -> "Mayiladuthurai")
val testClass = mapper.convertValue(map, classOf[Data])
...