Repository: phoenix Updated Branches: refs/heads/txn d10a52659 -> d3b85048a
add comment Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/d3b85048 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/d3b85048 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/d3b85048 Branch: refs/heads/txn Commit: d3b85048a751dbe07e8e98c85b04540bbea6e6e1 Parents: d10a526 Author: Thomas D'Silva <[email protected]> Authored: Fri Nov 13 14:08:14 2015 -0800 Committer: Thomas D'Silva <[email protected]> Committed: Fri Nov 13 14:08:14 2015 -0800 ---------------------------------------------------------------------- .../src/it/java/org/apache/phoenix/execute/PartialCommitIT.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/phoenix/blob/d3b85048/phoenix-core/src/it/java/org/apache/phoenix/execute/PartialCommitIT.java ---------------------------------------------------------------------- diff --git a/phoenix-core/src/it/java/org/apache/phoenix/execute/PartialCommitIT.java b/phoenix-core/src/it/java/org/apache/phoenix/execute/PartialCommitIT.java index a9ac5fa..11a6e67 100644 --- a/phoenix-core/src/it/java/org/apache/phoenix/execute/PartialCommitIT.java +++ b/phoenix-core/src/it/java/org/apache/phoenix/execute/PartialCommitIT.java @@ -259,6 +259,7 @@ public class PartialCommitIT { Connection con = driver.connect(url, new Properties()); PhoenixConnection phxCon = new PhoenixConnection(con.unwrap(PhoenixConnection.class)); final Map<TableRef,Map<ImmutableBytesPtr,MutationState.RowMutationState>> mutations = Maps.newTreeMap(new TableRefComparator()); + // passing null mutation state forces the connection.newMutationState() to be used to create the MutationState return new PhoenixConnection(phxCon, null) { @Override protected MutationState newMutationState(int maxSize) {
