Jackson Jodaの日付形式をシリアル化する方法は？

Question

Flinkストリーム処理ジョブの内部でオブジェクトをJsonにシリアル化する必要があります。フリンクジョブの内部では、すべてのオブジェクトをシリアライズ可能にする必要があります。

私はオブジェクトをシリアル化するためにジャクソンを使用しています。

java.io.NotSerializableException: com.fasterxml.jackson.datatype.joda.cfg.JacksonJodaDateFormat 

がどのように私は、シリアライズジョダモジュールなどのオブジェクトマッパーを行うことができます。

final ObjectMapper mapper = new ObjectMapper(); 
mapper.registerModule(new JodaModule()); 
mapper.disable(SerializationFeature.WRITE_DATES_AS_TIMESTAMPS); 

私はこれを使用していて、私は次の例外を取得しますか？

Answer 1

Flinkは、データオブジェクトをカスタムシリアライザでシリアル化します（未知のオブジェクトはKryoでシリアル化されています）。しかし、機能オブジェクト（すなわち、MapFunctionのような機能インタフェースを実装するクラスのオブジェクト）は、Java直列化を用いてクラスタに出荷される。

ここでの問題は、ObjectMapperクラスにシリアル化可能ではないフィールドがあるようです。 RichFunctionとしての機能を実装し、最初の前に呼び出されRichFunction.open()方法で非直列化可能フィールドを初期化する）は、Javaの直列化メソッドまたは 2を上書き）

1：あなたはtransientにフィールドを設定しようとすることができますどちらかレコードが処理されます。