串行circe.json flink

Question

scala flink 在 circe.json 格式中序列化JSON的问题。

我正在使用lib flink-adt type typeInformation 序列化器。

  implicit val jsonInfo: TypeInformation[Json] =
    deriveTypeInformation[Json]

这是错误消息：

magnolia: child class BiggerDecimalJsonNumber of class JsonNumber is neither final nor a case class

我还尝试了此。

  implicit val jsonInfo: TypeInformation[Json] =
    TypeInformation.of(classOf[Json])

它会编译，但是当我运行单位测试时崩溃。

Answer 1

我通过添加new executionConfig（）使用

该代码来使序列化器工作：

import io.circe._
import io.circe.syntax._
import org.apache.flink.api.common.typeinfo.TypeInformation
import org.apache.flink.api.common.ExecutionConfig

    implicit val jsonTypeInformation: TypeInformation[Json] =
      TypeInformation.of(classOf[Json])
    val typeInformation = implicitly[TypeInformation[Json]]
    val json = """[{"level":"up","num":1.23,"valid":true}]""".asJson
    val ser = typeInformation.createSerializer(new ExecutionConfig())
    roundtrip(ser, json)