Re: rowTime from json nested timestamp field in SQL-Client

Hi Timo, We want to add this functionality in a forked branch. Can you guide us with steps to quickly apply a patch/fix for the same? On Mon, Jul 16, 2018 at 9:06 PM Ashwin Sinha wrote: > Thanks Timo for the clarification, but our processing actually involves > aggregations on huge pas

Re: rowTime from json nested timestamp field in SQL-Client

Timo > > Am 16.07.18 um 14:25 schrieb Ashwin Sinha: > > Hi Users, > > In Flink1.5 SQL CLient > <https://ci.apache.org/projects/flink/flink-docs-release-1.5/dev/table/sqlClient.html>, > we are trying to define rowTime from a nested JSON element, but struggling > with

rowTime from json nested timestamp field in SQL-Client

where we can register nested timestamp field as rowTime for the source table? -- *Ashwin Sinha *| Data Engineer ashwin.si...@go-mmt.com | 9452075361 <https://www.makemytrip.com/> <https://www.goibibo.com/> <

Re: SinkFunction invoke method signature

the future > with additional methods.interface Context { > > > > org.apache.flink/flink-streaming-java_2.11/1.5.0/784a58515da2194a2e74666e8d53d50fac8c03/flink-streaming-java_2.11-1.5.0-sources.jar!/org/apache/flink/streaming/api/functions/sink/SinkFunction.java > --

Re: Issues with Flink1.5 SQL-Client

ge > but it might be related to that. > > Regards, > Timo > > > Am 03.07.18 um 14:42 schrieb Ashwin Sinha: > > Hi folks, > > We are trying to setup flink sql client > <https://ci.apache.org/projects/flink/flink-docs-release-1.5/dev/table/sqlClient.html>. >

Issues with Flink1.5 SQL-Client

the result shell hangs and after sometime it exits without printing any data and give following error on screen: https://pastebin.com/wuitQx1a Complete stacktrace in flink logs: https://pastebin.com/mgk06xeG Please assist us in resolving this! -- *Ashwin Sinha *| Data Engineer ashwin.si...@go-mm

Re: Regarding external metastore like HIVE

By metastore we mean catalog where table information is stored. On Tue 3 Jul, 2018, 13:23 Chesnay Schepler, wrote: > What do you mean with "Metastore"? Are you referring to state backends > > ? > > On 02.07.20

Some doubts related to Rocksdb state backed and checkpointing!

If we run aggregations on past data, then will it take help of state backend to not run aggregations again and give results by querying the state backend, saving the processing time? -- *Ashwin Sinha *| Data Engineer ashwin.si...@go-mmt.com | 9452075361 <https://www.makemytrip.com/> <http