[ANNOUNCE] Apache Flink Table Store 0.2.1 released

=g:org.apache.flink%20table-store The full release notes are available in Jira: https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&version=12352257 We would like to thank all contributors of the Apache Flink community who made this release possible! Best, Jingsong Lee

[ANNOUNCE] Apache Flink Table Store 0.1.0 released

=g:org.apache.flink%20table-store The full release notes are available in Jira: https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&version=12351234 We would like to thank all contributors of the Apache Flink community who made this release possible! Best, Jingsong Lee

[ANNOUNCE] Apache Flink 1.12.5 released

available in Jira: https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&version=12350166 We would like to thank all contributors of the Apache Flink community who made this release possible! Regards, Jingsong Lee

Re: Add time attribute column to POJO stream

his way to get nested field from POJO. Best, Jingsong Lee On Wed, Dec 4, 2019 at 12:33 AM Chris Miller wrote: > I'm having trouble dealing with a DataStream of POJOs. In particular, when > I perform SQL operations on it I can't figure out the syntax for referring > to indi

Re: How to write type information for a Java Set and List inside a Tuple?

(myClass.class))); >> >> >> >> Code Snippet 2: >> private final MapStateDescriptor, >> Set, List>> outStateDesc = >> new MapStateDescriptor<>( >> "neighbours", >> BasicTypeInfo.INT_TYPE_INFO, >> TypeInformation.of(new >> TypeHint, Set, List>>(){})); >> >> >> Best Regards, >> Komal >> > > > -- > Best, Jingsong Lee > -- Best, Jingsong Lee