Repository: phoenix Updated Branches: refs/heads/4.x-HBase-0.98 06e9c1f03 -> 6a88cfed3
PHOENIX-4605 Support running multiple transaction providers (ammendment) Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/6a88cfed Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/6a88cfed Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/6a88cfed Branch: refs/heads/4.x-HBase-0.98 Commit: 6a88cfed32b12781674d78057f83b7d3f4954b37 Parents: 06e9c1f Author: James Taylor <[email protected]> Authored: Thu Apr 12 18:11:19 2018 -0700 Committer: James Taylor <[email protected]> Committed: Thu Apr 12 18:15:51 2018 -0700 ---------------------------------------------------------------------- .../src/main/java/org/apache/phoenix/schema/MetaDataClient.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/phoenix/blob/6a88cfed/phoenix-core/src/main/java/org/apache/phoenix/schema/MetaDataClient.java ---------------------------------------------------------------------- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/schema/MetaDataClient.java b/phoenix-core/src/main/java/org/apache/phoenix/schema/MetaDataClient.java index 1f6cab3..d70b1bc 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/schema/MetaDataClient.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/schema/MetaDataClient.java @@ -3271,7 +3271,7 @@ public class MetaDataClient { // If changing isImmutableRows to true or it's not being changed and is already true boolean willBeImmutableRows = Boolean.TRUE.equals(metaPropertiesEvaluated.getIsImmutableRows()) || (metaPropertiesEvaluated.getIsImmutableRows() == null && table.isImmutableRows()); boolean willBeTxnl = metaProperties.getNonTxToTx(); - Long timeStamp = TransactionUtil.getTableTimestamp(connection, table.isTransactional() || willBeTxnl, metaPropertiesEvaluated.getTransactionProvider()); + Long timeStamp = TransactionUtil.getTableTimestamp(connection, table.isTransactional() || willBeTxnl, table.isTransactional() ? table.getTransactionProvider() : metaPropertiesEvaluated.getTransactionProvider()); int numPkColumnsAdded = 0; List<PColumn> columns = Lists.newArrayListWithExpectedSize(numCols); Set<String> colFamiliesForPColumnsToBeAdded = new LinkedHashSet<>();
