You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by st...@apache.org on 2016/01/15 15:00:19 UTC
hbase git commit: HBASE-15117 Resolve ICAST findbugs warnings in
current codes (Yu Li)
Repository: hbase
Updated Branches:
refs/heads/master 46ea5494a -> cb17c7a97
HBASE-15117 Resolve ICAST findbugs warnings in current codes (Yu Li)
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/cb17c7a9
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/cb17c7a9
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/cb17c7a9
Branch: refs/heads/master
Commit: cb17c7a97a1e2eb0ebd532f614191e4edbb9e49b
Parents: 46ea549
Author: stack <st...@apache.org>
Authored: Fri Jan 15 06:00:11 2016 -0800
Committer: stack <st...@apache.org>
Committed: Fri Jan 15 06:00:11 2016 -0800
----------------------------------------------------------------------
.../apache/hadoop/hbase/regionserver/compactions/Compactor.java | 2 +-
.../main/java/org/apache/hadoop/hbase/snapshot/ExportSnapshot.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/cb17c7a9/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/Compactor.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/Compactor.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/Compactor.java
index 660ea91..3728c7c 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/Compactor.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/Compactor.java
@@ -335,7 +335,7 @@ public abstract class Compactor {
int minFilesToCompact = Math.max(2,
conf.getInt(CompactionConfiguration.HBASE_HSTORE_COMPACTION_MIN_KEY,
/* old name */ conf.getInt("hbase.hstore.compactionThreshold", 3)));
- long shippedCallSizeLimit = minFilesToCompact * HConstants.DEFAULT_BLOCKSIZE;
+ long shippedCallSizeLimit = (long) minFilesToCompact * HConstants.DEFAULT_BLOCKSIZE;
try {
do {
hasMore = scanner.next(cells, scannerContext);
http://git-wip-us.apache.org/repos/asf/hbase/blob/cb17c7a9/hbase-server/src/main/java/org/apache/hadoop/hbase/snapshot/ExportSnapshot.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/snapshot/ExportSnapshot.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/snapshot/ExportSnapshot.java
index a574410..c0b2ce8 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/snapshot/ExportSnapshot.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/snapshot/ExportSnapshot.java
@@ -270,7 +270,7 @@ public class ExportSnapshot extends Configured implements Tool {
InputStream in = openSourceFile(context, inputInfo);
int bandwidthMB = context.getConfiguration().getInt(CONF_BANDWIDTH_MB, 100);
if (Integer.MAX_VALUE != bandwidthMB) {
- in = new ThrottledInputStream(new BufferedInputStream(in), bandwidthMB * 1024 * 1024);
+ in = new ThrottledInputStream(new BufferedInputStream(in), bandwidthMB * 1024 * 1024L);
}
try {