[jira] [Created] (FLINK-12754) alterTableColumnStatistics() in GenericInMemoryCatalog should ensure the table is non-partitioned

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-12754) alterTableColumnStatistics() in GenericInMemoryCatalog should ensure the table is non-partitioned

Shang Yuanchun (Jira)
Bowen Li created FLINK-12754:
--------------------------------

             Summary: 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: Sub-task
          Components: Table SQL / API
            Reporter: Bowen Li
             Fix For: 1.9.0


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
(v7.6.3#76005)