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 syntax.
JSON data format: https://pastebin.com/ByCLhEnF YML table config: https://pastebin.com/cgEtQPDQ Now, in above config, we want to access *payload.after.modifiedon *as rowTime column. We tried SQL query <https://pastebin.com/yCU4WWhK> with aggregation on 'payload.after.modifiedon' as time but get this <https://pastebin.com/bTbushYN> error. Is there anyway where we can register nested timestamp field as rowTime for the source table? -- *Ashwin Sinha *| Data Engineer ashwin.si...@go-mmt.com <shivam.sha...@go-mmt.com> | 9452075361 <https://www.makemytrip.com/> <https://www.goibibo.com/> <https://www.redbus.in/> -- ::DISCLAIMER:: ---------------------------------------------------------------------------------------------------------------------------------------------------- This message is intended only for the use of the addressee and may contain information that is privileged, confidential and exempt from disclosure under applicable law. If the reader of this message is not the intended recipient, or the employee or agent responsible for delivering the message to the intended recipient, you are hereby notified that any dissemination, distribution or copying of this communication is strictly prohibited. If you have received this e-mail in error, please notify us immediately by return e-mail and delete this e-mail and all attachments from your system.
