Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
Browse files

WIP3

  • Loading branch information...
commit 53e8def48e3e2fe4b113c782befd456d8842d415 1 parent fd0256d
Ivan Kelly authored
View
2  bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/Bookie.java
@@ -574,7 +574,7 @@ public void registerJMX(BKMBeanInfo parent) {
BKMBeanRegistry.getInstance().register(jmxBookieBean, parent);
try {
- jmxLedgerCacheBean = new LedgerCacheBean(this.ledgerCache);
+ jmxLedgerCacheBean = new LedgerCacheBean((LedgerCacheImpl)this.ledgerCache);
BKMBeanRegistry.getInstance().register(jmxLedgerCacheBean, jmxBookieBean);
} catch (Exception e) {
LOG.warn("Failed to register with JMX for ledger cache", e);
View
4 bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/LedgerCacheBean.java
@@ -25,9 +25,9 @@
*/
public class LedgerCacheBean implements LedgerCacheMXBean, BKMBeanInfo {
- final LedgerCache lc;
+ final LedgerCacheImpl lc;
- public LedgerCacheBean(LedgerCache lc) {
+ public LedgerCacheBean(LedgerCacheImpl lc) {
this.lc = lc;
}
View
6 bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/BookieServer.java
@@ -399,6 +399,12 @@ public void processPacket(ByteBuffer packet, Cnxn src) {
LOG.error("Error reading " + entryId + "@" + ledgerId, e);
}
errorCode = BookieProtocol.EIO;
+ } catch (BookieException e) {
+ // IKTODO, fix this up
+ if (LOG.isTraceEnabled()) {
+ LOG.error("Error reading " + entryId + "@" + ledgerId, e);
+ }
+ errorCode = BookieProtocol.EIO;
}
rsp[0] = buildResponse(errorCode, h.getVersion(), h.getOpCode(), ledgerId, entryId);
View
2  bookkeeper-server/src/test/resources/log4j.properties
@@ -26,7 +26,7 @@
# Format is "<default threshold> (, <appender>)+
# DEFAULT: console appender only
-log4j.rootLogger=INFO, CONSOLE
+log4j.rootLogger=OFF, CONSOLE
# Example with rolling log file
#log4j.rootLogger=DEBUG, CONSOLE, ROLLINGFILE
Please sign in to comment.
Something went wrong with that request. Please try again.