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

    server.addServlet(ListType.class, "/trace/listType");
    server.addServlet(ShowTrace.class, "/trace/show");
    LogService.startLogListener();
    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

    currentMaster = null;


    statsKeeper = new TabletStatsKeeper();


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


    String className = ServerConfiguration.getSystemConfiguration().get(Property.TSERV_LOGGER_STRATEGY);
    Class<? extends LoggerStrategy> klass = DEFAULT_LOGGER_STRATEGY;

View Full Code Here

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

      }


      // add the assignment job to the appropriate queue
      log.info("Loading tablet " + extent);


      final Runnable ah = new LoggingRunnable(log, new AssignmentHandler(extent));
      // Root tablet assignment must take place immediately
      if (extent.compareTo(Constants.ROOT_TABLET_EXTENT) == 0) {
        new Thread("Root Tablet Assignment") {
          @Override
          public void run() {
            ah.run();
            if (onlineTablets.containsKey(extent)) {
              log.info("Root tablet loaded: " + extent);
            } else {
              log.info("Root tablet failed to load");
            }

View Full Code Here

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

        throw new RuntimeException(e);
      }


      KeyExtent extent = new KeyExtent(textent);


      resourceManager.addMigration(extent, new LoggingRunnable(log, new UnloadTabletHandler(extent, save)));
    }

View Full Code Here

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

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

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

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

            Tablet tablet = entry.getValue();


            // if we need to split AND compact, we need a good way
            // to decide what to do
            if (tablet.needsSplit()) {
              resourceManager.executeSplit(tablet.getExtent(), new LoggingRunnable(log, new SplitRunner(tablet)));
              continue;
            }


            int maxLogEntriesPerTablet = ServerConfiguration.getTableConfiguration(tablet.getExtent().getTableId().toString()).getCount(
                Property.TABLE_MINC_LOGS_MAX);

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(extentToOpen, retryAttempt + 1);
              if (isMetaDataTablet) {
                if (Constants.ROOT_TABLET_EXTENT.equals(extent)) {
                  new Thread(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

              completeFailures.put(mapFile, empty);
            } else
              assignments.put(mapFile, tabletsToAssignMapFileTo);
          }
        };
        threadPool.submit(new TraceRunnable(new LoggingRunnable(log, getAssignments)));
      }
      threadPool.shutdown();
      while (!threadPool.isTerminated()) {
        try {
          threadPool.awaitTermination(60, TimeUnit.SECONDS);

View Full Code Here

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

          
          ais.put(entry.getKey(), assignmentInfoList);
        }
      };
      
      threadPool.submit(new TraceRunnable(new LoggingRunnable(log, estimationTask)));
    }
    
    threadPool.shutdown();
    
    while (!threadPool.isTerminated()) {

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.