I have POJO with java.time.OffsetDateTime, which I...
# troubleshooting
m
I have POJO with java.time.OffsetDateTime, which I try to move into table API
Copy code
class POJO {
   OffsetDateTime created_at;
}

Table table = tEnv.fromDataStream(stream,
    Schema.newBuilder()
    .columnByExpression("proc_time", "PROCTIME()")
    .build()
);
It parse the time as RAW
Copy code
(
  `created_at` RAW('java.time.OffsetDateTime', '...'),
  `proc_time` TIMESTAMP_LTZ(3) NOT NULL *PROCTIME* AS PROCTIME()
)
any idea why? the documentation says it should be compatible
I understood OffsetDateTime is not supported yet and the docs are misleading. I tried to create my own
TypeSerializer<OffsetDateTime>
and annotate the field
Copy code
@DataTypeHint(value = "RAW", rawSerializer = OffsetDateTimeSerializer.class, bridgedTo = OffsetDateTime.class)
public OffsetDateTime created_at;
but now I'm getting:
Copy code
Query schema: [created_at: RAW('java.time.OffsetDateTime', '...')]
Sink schema:  [created_at: RAW('java.time.OffsetDateTime', '...')]