Hi, The exception shows your SQL statement has grammatical errors. Please check it again or provide the whole SQL statement here.
Best, Vino srikanth flink <flink.d...@gmail.com> 于2019年10月29日周二 下午2:51写道： > Hi there, > > I'm querying json data and is working fine. I would like to add custom > fields including the query result. > My query looks like: select ROW(`source`), ROW(`destination`), > ROW(`dns`), organization, cnt from (select > (source.`ip`,source.`isInternalIP`) as source, > (destination.`ip`,destination.`isInternalIP`) as destination, > (dns.`query`, dns.`answers`.`data`) as dns, organization as organization > from dnsTableS) tab1; > > While I would like to add "'dns' as `agg.type`, 'dns' as `agg.name`" to > the same output, but the query is throw exceptions: > [ERROR] Could not execute SQL statement. Reason: > org.apache.flink.sql.parser.impl.ParseException: Encountered "." at line > 1, column 278. > Was expecting one of: > "EXCEPT" ... > "FETCH" ... > "FROM" ... > "INTERSECT" ... > "LIMIT" ... > "OFFSET" ... > "ORDER" ... > "MINUS" ... > "UNION" ... > ")" ... > "," ... > > Could someone help me with this? Thanks > > Srikanth >
