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

> > 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 synta

rowTime from json nested timestamp field in SQL-Client

an 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/> <https://ww

Re: SinkFunction invoke method signature

itional 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 > -- *Ashwin Sinha *| Data En

Re: Issues with Flink1.5 SQL-Client

ssage > 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

e] 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

Some doubts related to Rocksdb state backed and checkpointing!

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/> <https://www.go