What exceptions do you actually receive - can you send them here? Knowing that is key to addressing your issue.
On Tue, Feb 5, 2013 at 1:50 AM, Bing Li <lbl...@gmail.com> wrote: > Dear all, > > When writing data into HBase, sometimes I got exceptions. I guess they > might be caused by concurrent writings. But I am not sure. > > My question is whether it is necessary to put "synchronized" before > the writing methods? The following lines are the sample code. > > I think the directive, synchronized, must lower the performance of > writing. Sometimes concurrent writing is needed in my system. > > Thanks so much! > > Best wishes, > Bing > > public synchronized void AddDomainNodeRanks(String domainKey, int > timingScale, Map<String, Double> nodeRankMap) > { > List<Put> puts = new ArrayList<Put>(); > Put domainKeyPut; > Put timingScalePut; > Put nodeKeyPut; > Put rankPut; > > byte[] domainNodeRankRowKey; > > for (Map.Entry<String, Double> nodeRankEntry : nodeRankMap.entrySet()) > { > domainNodeRankRowKey = > Bytes.toBytes(RankStructure.DOMAIN_NODE_RANK_ROW + > Tools.GetAHash(domainKey + timingScale + nodeRankEntry.getKey())); > > domainKeyPut = new Put(domainNodeRankRowKey); > domainKeyPut.add(RankStructure.DOMAIN_NODE_RANK_FAMILY, > RankStructure.DOMAIN_NODE_RANK_DOMAIN_KEY_COLUMN, > Bytes.toBytes(domainKey)); > puts.add(domainKeyPut); > > timingScalePut = new Put(domainNodeRankRowKey); > timingScalePut.add(RankStructure.DOMAIN_NODE_RANK_FAMILY, > RankStructure.DOMAIN_NODE_RANK_TIMING_SCALE_COLUMN, > Bytes.toBytes(timingScale)); > puts.add(timingScalePut); > > nodeKeyPut = new Put(domainNodeRankRowKey); > nodeKeyPut.add(RankStructure.DOMAIN_NODE_RANK_FAMILY, > RankStructure.DOMAIN_NODE_RANK_NODE_KEY_COLUMN, > Bytes.toBytes(nodeRankEntry.getKey())); > puts.add(nodeKeyPut); > > rankPut = new Put(domainNodeRankRowKey); > rankPut.add(RankStructure.DOMAIN_NODE_RANK_FAMILY, > RankStructure.DOMAIN_NODE_RANK_RANKS_COLUMN, > Bytes.toBytes(nodeRankEntry.getValue())); > puts.add(rankPut); > } > > try > { > this.rankTable.put(puts); > } > catch (IOException e) > { > e.printStackTrace(); > } > } -- Harsh J