Examples of LoggingRunnable

ch.qos.logback.classic.issue.lbclassic135.LoggingRunnable
com.cloudera.oryx.common.lang.LoggingRunnable
A {@link Runnable} that logs errors thrown from {@link #run()}. Useful in cases where it would otherwise silently disappear into an executor.
org.apache.accumulo.core.util.LoggingRunnable
org.apache.accumulo.fate.util.LoggingRunnable
org.elasticsearch.common.thread.LoggingRunnable

Examples of org.apache.accumulo.core.util.LoggingRunnable

      }
      
    };
    
    try {
      reportExecutor.execute(new LoggingRunnable(log, r));
    } catch (RejectedExecutionException ree) {
      log.error("Failed to report problem " + pr.getTableName() + " " + pr.getProblemType() + " " + pr.getResource() + "  " + ree.getMessage());
    }
    
  }

View Full Code Here

Examples of org.apache.accumulo.core.util.LoggingRunnable

        }
      }
    };
    
    try {
      reportExecutor.execute(new LoggingRunnable(log, r));
    } catch (RejectedExecutionException ree) {
      log.error("Failed to delete problem report " + pr.getTableName() + " " + pr.getProblemType() + " " + pr.getResource() + "  " + ree.getMessage());
    }
  }

View Full Code Here

Examples of org.apache.accumulo.core.util.LoggingRunnable

  boolean isMajorCompactionDisabled() {
    return majorCompactorDisabled;
  }
  
  void executeSplit(Tablet tablet) {
    resourceManager.executeSplit(tablet.getExtent(), new LoggingRunnable(log, new SplitRunner(tablet)));
  }

View Full Code Here

Examples of org.apache.accumulo.core.util.LoggingRunnable

    currentMaster = null;
    
    statsKeeper = new TabletStatsKeeper();
    
    // start major compactor
    majorCompactorThread = new Daemon(new LoggingRunnable(log, new MajorCompactor()));
    majorCompactorThread.setName("Split/MajC initiator");
    majorCompactorThread.start();
  }

View Full Code Here

Examples of org.apache.accumulo.core.util.LoggingRunnable

    if (server.isUsingSsl())
      server.addServlet(ShellServlet.class, "/shell");
    LogService.startLogListener(Monitor.getSystemConfiguration());
    server.start();
    
    new Daemon(new LoggingRunnable(log, new ZooKeeperStatus()), "ZooKeeperStatus").start();
    
    // need to regularly fetch data so plot data is updated
    new Daemon(new LoggingRunnable(log, new Runnable() {
      
      @Override
      public void run() {
        while (true) {
          try {

View Full Code Here

Examples of org.apache.accumulo.core.util.LoggingRunnable

          if (ltp == null) {
            // load the bloom filter in the foreground
            loadTask.run();
          } else {
            // load the bloom filter in the background
            ltp.execute(new LoggingRunnable(LOG, loadTask));
          }
        } finally {
          // set load task to null so no one else can initiate the load
          loadTask = null;
        }

View Full Code Here

Examples of org.apache.accumulo.core.util.LoggingRunnable

          public void run() {
            log.info("adding tablet " + extent + " back to the assignment pool (retry " + retryAttempt + ")");
            AssignmentHandler handler = new AssignmentHandler(extent, retryAttempt + 1);
            if (extent.isMeta()) {
              if (extent.isRootTablet()) {
                new Daemon(new LoggingRunnable(log, handler), "Root tablet assignment retry").start();
              } else {
                resourceManager.addMetaDataAssignment(handler);
              }
            } else {
              resourceManager.addAssignment(handler);

View Full Code Here

Examples of org.apache.accumulo.core.util.LoggingRunnable

        } catch (Error e) {
          Halt.halt("Unexpected error in TThreadPoolServer " + e + ", halting.");
        }
      }
    };
    serveTask = new LoggingRunnable(TServerUtils.log, serveTask);
    Thread thread = new Daemon(serveTask, threadName);
    thread.start();
    return result;
  }

View Full Code Here

Examples of org.apache.accumulo.core.util.LoggingRunnable

        public void run() {
          processTabletMemStats();
        }
      };
      
      Thread t1 = new Daemon(new LoggingRunnable(log, r1));
      t1.setPriority(Thread.NORM_PRIORITY + 1);
      t1.setName("Accumulo Memory Guard");
      t1.start();
      
      Runnable r2 = new Runnable() {
        public void run() {
          manageMemory();
        }
      };
      
      Thread t2 = new Daemon(new LoggingRunnable(log, r2));
      t2.setName("Accumulo Minor Compaction Initiator");
      t2.start();
      
    }

View Full Code Here

Examples of org.apache.accumulo.core.util.LoggingRunnable

    
    // tablets call this method to run minor compactions,
    // this allows us to control how many minor compactions
    // run concurrently in a tablet server
    void executeMinorCompaction(final Runnable r) {
      minorCompactionThreadPool.execute(new LoggingRunnable(log, r));
    }

View Full Code Here

0 1 2 3 4 5

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.