This is an automated email from the ASF dual-hosted git repository. dlych pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/asterixdb.git
commit 51d67236270ecd7a3488b3440e6f7c03eb283812 Author: Murtadha Hubail <[email protected]> AuthorDate: Thu Dec 27 23:12:24 2018 +0300 [ASTERIXDB-2503][MD] Consider Datasets Alternating ID - user model changes: no - storage format changes: no - interface changes: no Details: - When initializing the DatasetIdFactory, consider the alternating id of datasets to avoid reusing ids. Change-Id: I2a3ee8f3b998c92afef5e793c7b697682fbf1f17 Reviewed-on: https://asterix-gerrit.ics.uci.edu/3099 Sonar-Qube: Jenkins <[email protected]> Tested-by: Jenkins <[email protected]> Integration-Tests: Jenkins <[email protected]> Reviewed-by: Till Westmann <[email protected]> --- .../src/main/java/org/apache/asterix/metadata/MetadataNode.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/MetadataNode.java b/asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/MetadataNode.java index abea47f..8cecb9e 100644 --- a/asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/MetadataNode.java +++ b/asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/MetadataNode.java @@ -1371,7 +1371,8 @@ public class MetadataNode implements IMetadataNode { rangeCursor.next(); final ITupleReference ref = rangeCursor.getTuple(); final Dataset ds = valueExtractor.getValue(txnId, ref); - int datasetId = ds.getDatasetId(); + int datasetId = Math.max(ds.getDatasetId(), + DatasetIdFactory.generateAlternatingDatasetId(ds.getDatasetId())); if (mostRecentDatasetId < datasetId) { mostRecentDatasetId = datasetId; }
