Repository: phoenix Updated Branches: refs/heads/5.x-HBase-2.0 d081adced -> 0fcd9de8b
PHOENIX-4472 Altering properties in the table descriptor is not working properly. Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/0fcd9de8 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/0fcd9de8 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/0fcd9de8 Branch: refs/heads/5.x-HBase-2.0 Commit: 0fcd9de8b69e9d996af1f4420c247615bc1767d9 Parents: d081adc Author: Ankit Singhal <ankitsingha...@gmail.com> Authored: Fri Dec 22 13:17:25 2017 +0530 Committer: Ankit Singhal <ankitsingha...@gmail.com> Committed: Fri Dec 22 13:17:25 2017 +0530 ---------------------------------------------------------------------- .../java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/phoenix/blob/0fcd9de8/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 c273bd4..5c5a42e 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 @@ -1923,6 +1923,7 @@ public class ConnectionQueryServicesImpl extends DelegateQueryServices implement ColumnFamilyDescriptor tableColDescriptor = tableDescriptor.getColumnFamily(familyName); indexColDescriptorBuilder.setMaxVersions(tableColDescriptor.getMaxVersions()); indexColDescriptorBuilder.setValue( Bytes.toBytes(PhoenixTransactionContext.PROPERTY_TTL),tableColDescriptor.getValue(Bytes.toBytes(PhoenixTransactionContext.PROPERTY_TTL))); + indexDescriptorBuilder.removeColumnFamily(familyName); indexDescriptorBuilder.addColumnFamily(indexColDescriptorBuilder.build()); } else { for (PColumnFamily family : table.getColumnFamilies()) { @@ -1933,6 +1934,7 @@ public class ConnectionQueryServicesImpl extends DelegateQueryServices implement ColumnFamilyDescriptorBuilder indexColDescriptorBuilder = ColumnFamilyDescriptorBuilder.newBuilder(indexColDescriptor); indexColDescriptorBuilder.setMaxVersions(tableColDescriptor.getMaxVersions()); indexColDescriptorBuilder.setValue( Bytes.toBytes(PhoenixTransactionContext.PROPERTY_TTL),tableColDescriptor.getValue(Bytes.toBytes(PhoenixTransactionContext.PROPERTY_TTL))); + indexDescriptorBuilder.removeColumnFamily(familyName); indexDescriptorBuilder.addColumnFamily(indexColDescriptorBuilder.build()); } }
