[FLINK-18342] SQLParser can not parse ROW() if it contains UDF

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Duplicate
• Component/s: Table SQL / Planner
• Assignee: Unassigned
• Reporter: Leonard Xu
• Created: 17/Jun/20 07:10
• Updated: 17/Jun/20 07:24
• Resolved: 17/Jun/20 07:24

Description

// code to reproduce

CREATE TABLE MyHBaseSource (
  rowkey STRING,
  family1 ROW<f1c1 STRING>,
  family2 ROW<f2c1 STRING, f2c2 STRING>
) WITH (
  'connector' = 'hbase-1.4',
  'table-name' = 'source',
  'zookeeper.quorum' = 'localhost:2181',
  'zookeeper.znode.parent' = '/hbase'
);
CREATE FUNCTION RegReplace AS 'org.apache.flink.table.toolbox.StringRegexReplaceFunction';

INSERT INTO MyHBaseSink
  SELECT
  rowkey,
  ROW(RegReplace(family1.f1c1, 'v', 'value'))
FROM MyHBaseSource;

//exception
[ERROR] Could not execute SQL statement. Reason:
org.apache.flink.sql.parser.impl.ParseException: Encountered "(" at line 4, column 19.
 Was expecting one of:
     ")" ...
     "," ...

Issue Links

• is related to: FLINK-18027 ROW value constructor cannot deal with complex expressions