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 <[email protected]> Authored: Fri Jan 15 06:00:11 2016 -0800 Committer: stack <[email protected]> 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 {
