Hello, Do both of the types you use have the same nullability? For a primitive int, the documentation you referred to says: "Output only if type is not nullable".
Regards, Roman On Tue, Nov 17, 2020 at 7:49 AM Rex Fenley <r...@remind101.com> wrote: > Hello, > > I'm using the Table API and I have a column which is an integer day since > epoch. According to the docs [1] both `int` and `java.lang.Integer` are > acceptable for DATE. However, if I try to use the SQL API to write a DATE > out to the Elasticsearch connector for the INT column I receive an > exception. How then should I go about converting to DATE? > > Exception: > Caused by: org.apache.flink.table.api.ValidationException: Field types of > query result and registered TableSink > default_catalog.default_database.sink_es_people do not match. > Query schema: [... column: INT, ...] > Sink schema: [... column: DATE, ...] > > I know this column is the culprit because when I make it INT on both ends > it works. > > How do I go about making my INT a DATE? > > Thanks! > > [1] > https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/types.html#date-and-time > > -- > > Rex Fenley | Software Engineer - Mobile and Backend > > > Remind.com <https://www.remind.com/> | BLOG <http://blog.remind.com/> | > FOLLOW US <https://twitter.com/remindhq> | LIKE US > <https://www.facebook.com/remindhq> >
