You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by bi...@apache.org on 2012/10/17 07:18:16 UTC
svn commit: r1399099 - in /pig/trunk: CHANGES.txt
src/org/apache/pig/backend/hadoop/hbase/HBaseStorage.java
Author: billgraham
Date: Wed Oct 17 05:18:16 2012
New Revision: 1399099
URL: http://svn.apache.org/viewvc?rev=1399099&view=rev
Log:
PIG-2976: Reduce HBaseStorage logging (billgraham)
Modified:
pig/trunk/CHANGES.txt
pig/trunk/src/org/apache/pig/backend/hadoop/hbase/HBaseStorage.java
Modified: pig/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/pig/trunk/CHANGES.txt?rev=1399099&r1=1399098&r2=1399099&view=diff
==============================================================================
--- pig/trunk/CHANGES.txt (original)
+++ pig/trunk/CHANGES.txt Wed Oct 17 05:18:16 2012
@@ -24,6 +24,8 @@ INCOMPATIBLE CHANGES
IMPROVEMENTS
+PIG-2976: Reduce HBaseStorage logging (billgraham)
+
PIG-2943: DevTests, Refactor Windows checks to use new Util.WINDOWS method for code health (jgordon via dvryaboy)
PIG-2966: Test failures on CentOS 6 because MALLOC_ARENA_MAX is not set (cheolsoo via sms)
Modified: pig/trunk/src/org/apache/pig/backend/hadoop/hbase/HBaseStorage.java
URL: http://svn.apache.org/viewvc/pig/trunk/src/org/apache/pig/backend/hadoop/hbase/HBaseStorage.java?rev=1399099&r1=1399098&r2=1399099&view=diff
==============================================================================
--- pig/trunk/src/org/apache/pig/backend/hadoop/hbase/HBaseStorage.java (original)
+++ pig/trunk/src/org/apache/pig/backend/hadoop/hbase/HBaseStorage.java Wed Oct 17 05:18:16 2012
@@ -410,8 +410,8 @@ public class HBaseStorage extends LoadFu
if (colInfo.isColumnMap()) {
- if (LOG.isInfoEnabled()) {
- LOG.info("Adding family:prefix filters with values " +
+ if (LOG.isDebugEnabled()) {
+ LOG.debug("Adding family:prefix filters with values " +
Bytes.toString(colInfo.getColumnFamily()) + COLON +
Bytes.toString(colInfo.getColumnPrefix()));
}
@@ -425,8 +425,8 @@ public class HBaseStorage extends LoadFu
}
else {
- if (LOG.isInfoEnabled()) {
- LOG.info("Adding family:descriptor filters with values " +
+ if (LOG.isDebugEnabled()) {
+ LOG.debug("Adding family:descriptor filters with values " +
Bytes.toString(colInfo.getColumnFamily()) + COLON +
Bytes.toString(colInfo.getColumnName()));
}
@@ -446,8 +446,8 @@ public class HBaseStorage extends LoadFu
}
private void addRowFilter(CompareOp op, byte[] val) {
- if (LOG.isInfoEnabled()) {
- LOG.info("Adding filter " + op.toString() +
+ if (LOG.isDebugEnabled()) {
+ LOG.debug("Adding filter " + op.toString() +
" with value " + Bytes.toStringBinary(val));
}
addFilter(new RowFilter(op, new BinaryComparator(val)));