-
Notifications
You must be signed in to change notification settings - Fork 3.4k
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
[Fix](multi catalog)(planner) Fix external table statistic collection bug. #16486
Conversation
@@ -85,7 +86,7 @@ protected void getColumnStatsByMeta() throws Exception { | |||
Map<String, String> parameters = table.getRemoteTable().getParameters(); | |||
// Collect table level row count, null number and timestamp. | |||
setParameterData(parameters, params); | |||
params.put("id", String.valueOf(tbl.getId()) + "-" + String.valueOf(col.getName())); | |||
params.put("id", String.valueOf(tbl.getId()) + "--1-" + col.getName()); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I think we should extract a method to do this, currently, it is very error prone
@@ -294,6 +294,7 @@ public Partition getPartition(List<String> partitionValues) { | |||
|
|||
@Override | |||
public List<Column> initSchema() { | |||
makeSureInitialized(); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Why need this?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Without this initialization, FE will throw NPE when excuting analyze table hms_catalog.db.table
immediately after FE started.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
… bug (#16486) Add index id to column statistic id. Refresh statistic cache after analyze.
… bug (apache#16486) Add index id to column statistic id. Refresh statistic cache after analyze.
Proposed changes
Issue Number: close #xxx
Problem summary
Add index id to column statistic id. Refresh statistic cache after analyze.
Checklist(Required)
Further comments
If this is a relatively large or complex change, kick off the discussion at [email protected] by explaining why you chose the solution you did and what alternatives you considered, etc...