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:21 GMT
Repository: phoenix
Updated Branches:
  refs/heads/4.14-HBase-1.1 8e5356420 -> 1d3cc5e6a


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/1d3cc5e6
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/1d3cc5e6
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/1d3cc5e6

Branch: refs/heads/4.14-HBase-1.1
Commit: 1d3cc5e6ae44be6da706502834e71410c1fe92a3
Parents: 8e53564
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:06:18 2018 -0700

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


http://git-wip-us.apache.org/repos/asf/phoenix/blob/1d3cc5e6/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 8f7f031..79ba0d5 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
@@ -3733,6 +3733,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