Repository: phoenix Updated Branches: refs/heads/4.x-HBase-1.0 bcfff122c -> 3a855a042
PHOENIX-2616 Indexes over immutable tables not marked as immutable Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/3a855a04 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/3a855a04 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/3a855a04 Branch: refs/heads/4.x-HBase-1.0 Commit: 3a855a042f596a8f1165dc834b1bf64e83e322c1 Parents: bcfff12 Author: James Taylor <[email protected]> Authored: Wed Jan 20 19:09:19 2016 -0800 Committer: James Taylor <[email protected]> Committed: Wed Jan 20 19:11:49 2016 -0800 ---------------------------------------------------------------------- .../apache/phoenix/query/ConnectionQueryServicesImpl.java | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/phoenix/blob/3a855a04/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java ---------------------------------------------------------------------- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java b/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java index cfe93a4..ec3aa30 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java @@ -2427,6 +2427,9 @@ public class ConnectionQueryServicesImpl extends DelegateQueryServices implement // Drop old stats table so that new stats table is created metaConnection = dropStatsTable(metaConnection, MetaDataProtocol.MIN_SYSTEM_TABLE_TIMESTAMP_4_7_0); + // Clear the server cache so the above changes make it over to any clients + // that already have cached data. + clearCache(); } } @@ -2621,11 +2624,6 @@ public class ConnectionQueryServicesImpl extends DelegateQueryServices implement throw sqlE; } } - metaConnection.removeTable(null, PhoenixDatabaseMetaData.SYSTEM_SCHEMA_NAME, - PhoenixDatabaseMetaData.SYSTEM_STATS_TABLE, MetaDataProtocol.MIN_SYSTEM_TABLE_TIMESTAMP); - clearTableFromCache(ByteUtil.EMPTY_BYTE_ARRAY, PhoenixDatabaseMetaData.SYSTEM_SCHEMA_NAME_BYTES, - PhoenixDatabaseMetaData.SYSTEM_STATS_TABLE_BYTES, MetaDataProtocol.MIN_SYSTEM_TABLE_TIMESTAMP); - clearTableRegionCache(PhoenixDatabaseMetaData.SYSTEM_STATS_NAME_BYTES); return metaConnection; }
