Made getColumnsInternal method synchronized to prevent ConcurrentModificationExceptions when columns are retrieved from the Table in an parallel manner.
Project: http://git-wip-us.apache.org/repos/asf/metamodel/repo Commit: http://git-wip-us.apache.org/repos/asf/metamodel/commit/38d8bc3e Tree: http://git-wip-us.apache.org/repos/asf/metamodel/tree/38d8bc3e Diff: http://git-wip-us.apache.org/repos/asf/metamodel/diff/38d8bc3e Branch: refs/heads/master Commit: 38d8bc3e18c6f966c2ef0fe661532d177e9359ee Parents: 0ffeeb2 Author: arjansh <arjan.seijk...@humaninference.com> Authored: Wed May 16 13:39:26 2018 +0200 Committer: arjansh <arjan.seijk...@humaninference.com> Committed: Wed May 16 13:39:26 2018 +0200 ---------------------------------------------------------------------- hbase/src/main/java/org/apache/metamodel/hbase/HBaseTable.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/metamodel/blob/38d8bc3e/hbase/src/main/java/org/apache/metamodel/hbase/HBaseTable.java ---------------------------------------------------------------------- diff --git a/hbase/src/main/java/org/apache/metamodel/hbase/HBaseTable.java b/hbase/src/main/java/org/apache/metamodel/hbase/HBaseTable.java index 03c3263..def7c9c 100644 --- a/hbase/src/main/java/org/apache/metamodel/hbase/HBaseTable.java +++ b/hbase/src/main/java/org/apache/metamodel/hbase/HBaseTable.java @@ -92,7 +92,7 @@ final class HBaseTable extends MutableTable { } @Override - protected List<Column> getColumnsInternal() { + protected synchronized List<Column> getColumnsInternal() { final List<Column> columnsInternal = super.getColumnsInternal(); if (columnsInternal.isEmpty() && _dataContext != null) { try {
