flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Bowen Li (Jira)" <j...@apache.org>
Subject [jira] [Updated] (FLINK-12754) alterTableColumnStatistics() in GenericInMemoryCatalog should ensure the table is non-partitioned
Date Thu, 14 Nov 2019 21:02:00 GMT

     [ https://issues.apache.org/jira/browse/FLINK-12754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Bowen Li updated FLINK-12754:
-----------------------------
        Parent:     (was: FLINK-12753)
    Issue Type: Task  (was: Sub-task)

> alterTableColumnStatistics() in GenericInMemoryCatalog should ensure the table is non-partitioned
> -------------------------------------------------------------------------------------------------
>
>                 Key: FLINK-12754
>                 URL: https://issues.apache.org/jira/browse/FLINK-12754
>             Project: Flink
>          Issue Type: Task
>          Components: Table SQL / API
>            Reporter: Bowen Li
>            Assignee: Louis Xu
>            Priority: Major
>              Labels: pull-request-available
>          Time Spent: 10m
>  Remaining Estimate: 0h
>
> Currently logic (below) doesn't check if the partition is partitioned or not.
> {code:java}
> 	@Override
> 	public void alterTableStatistics(ObjectPath tablePath, CatalogTableStatistics tableStatistics,
boolean ignoreIfNotExists)
> 			throws TableNotExistException {
> 		checkNotNull(tablePath);
> 		checkNotNull(tableStatistics);
> 		if (tableExists(tablePath)) {
> 			tableStats.put(tablePath, tableStatistics.copy());
> 		} else if (!ignoreIfNotExists) {
> 			throw new TableNotExistException(getName(), tablePath);
> 		}
> 	}
> {code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Mime
View raw message