-
Notifications
You must be signed in to change notification settings - Fork 1.1k
[core] Fix Identifier should parse backquote. #5390
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
base: master
Are you sure you want to change the base?
[core] Fix Identifier should parse backquote. #5390
Conversation
I doubt whether the feature is necessary, because Flink regards `example.view` as a whole table name differ from Spark. refer to https://nightlies.apache.org/flink/flink-docs-release-1.20/docs/dev/table/common/#expanding-table-identifiers On the other hand, the feature cannot deal with legal |
Thanks for your comment. But i think this has nothing to do with flink.
And i will fix this case |
Sure, @JingsongLi WDYT. Do we need to implement a parser to parse the table name like spark procedure do? |
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 :
Why :
Flink use
org.apache.paimon.catalog.Identifier
to parse thetableName
and miss processing backquote,spark use
spark.sessionState().sqlParser().parseMultipartIdentifier
to parse.Purpose
Linked issue: close #xxx
Tests
API and Format
Documentation