phoenix-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vincentp...@apache.org
Subject phoenix git commit: PHOENIX-4960 Write to table with global index failed if meta of index changed (split, move, etc)
Date Mon, 22 Oct 2018 19:06:02 GMT
Repository: phoenix
Updated Branches:
  refs/heads/4.14-HBase-1.3 e24b0cf56 -> af24d65ab


PHOENIX-4960 Write to table with global index failed if meta of index changed (split, move,
etc)


Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/af24d65a
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/af24d65a
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/af24d65a

Branch: refs/heads/4.14-HBase-1.3
Commit: af24d65ab3b33043bb36a7e9ab2da2e919cc9ce0
Parents: e24b0cf
Author: Vincent Poon <vincentpoon@apache.org>
Authored: Mon Oct 15 19:11:40 2018 -0700
Committer: Vincent Poon <vincentpoon@apache.org>
Committed: Mon Oct 22 12:05:59 2018 -0700

----------------------------------------------------------------------
 .../org/apache/phoenix/coprocessor/MetaDataEndpointImpl.java     | 4 ++++
 1 file changed, 4 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/phoenix/blob/af24d65a/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/MetaDataEndpointImpl.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/MetaDataEndpointImpl.java
b/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/MetaDataEndpointImpl.java
index ea72a01..68f8abf 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/MetaDataEndpointImpl.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/MetaDataEndpointImpl.java
@@ -3902,6 +3902,10 @@ public class MetaDataEndpointImpl extends MetaDataProtocol implements
Coprocesso
                             newKVs.remove(disableTimeStampKVIndex);
                             newKVs.set(indexStateKVIndex, KeyValueUtil.newKeyValue(key, TABLE_FAMILY_BYTES,
                                     INDEX_STATE_BYTES, timeStamp, Bytes.toBytes(newState.getSerializedValue())));
+                        } else if (disableTimeStampKVIndex == -1) { // clear disableTimestamp
if client didn't pass it in
+                            newKVs.add(KeyValueUtil.newKeyValue(key, TABLE_FAMILY_BYTES,
+                                PhoenixDatabaseMetaData.INDEX_DISABLE_TIMESTAMP_BYTES, timeStamp,
PLong.INSTANCE.toBytes(0)));
+                            disableTimeStampKVIndex = newKVs.size() - 1;
                         }
                     } else if (newState == PIndexState.DISABLE) {
                         //reset the counter for pending disable when transitioning from PENDING_DISABLE
to DISABLE


Mime
View raw message