paimon icon indicating copy to clipboard operation
paimon copied to clipboard

[core] Fix Identifier should parse backquote.

Open LinMingQiang opened this issue 7 months ago • 6 comments
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`.

image

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

Tests

API and Format

Documentation

LinMingQiang avatar Apr 02 '25 09:04 LinMingQiang