Repository: phoenix Updated Branches: refs/heads/4.x-HBase-1.3 7f37966c1 -> e79228c4f
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/e79228c4 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/e79228c4 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/e79228c4 Branch: refs/heads/4.x-HBase-1.3 Commit: e79228c4f35fafedd7a5c7ded0c053fc561846e7 Parents: 7f37966 Author: James Taylor <[email protected]> Authored: Thu Apr 12 18:11:19 2018 -0700 Committer: James Taylor <[email protected]> Committed: Thu Apr 12 18:11:19 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/e79228c4/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 3c7a837..1fb668e 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 @@ -3276,7 +3276,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<>();
