paimon
paimon copied to clipboard
[core] Fix Identifier should parse backquote.
trafficstars
When using flink procedure, table name can not parsed correctly when use `` quote.
But Spark request use `` for SYSTEM_TABLE_SPLITTER ($) . So this is incompatible with Spark.
e.g :
Flink is OK But Spark is ERR : CALL sys.create_branch('default.T$branch_branch1', ......)
Flink is ERR But Spark is OK : CALL sys.create_branch('default.`T$branch_branch1`', ......)
Flink will parse `T$branch_branch1` to table is `T and branch is branch_branch1`.
Why :
Flink use org.apache.paimon.catalog.Identifier to parse the tableName and miss processing backquote,
spark use spark.sessionState().sqlParser().parseMultipartIdentifier to parse.
Purpose
Linked issue: close #xxx