version and cleanup.

Author: dstreev

pom.xml

@@ -22,7 +22,7 @@
 
     <groupId>com.cloudera.utils.hive</groupId>
     <artifactId>hive-sre</artifactId>
-    <version>2.4.0.15-SNAPSHOT</version>
+    <version>2.4.0.15.1-SNAPSHOT</version>
 
     <name>hive-sre</name>
 

src/main/java/com/cloudera/utils/hive/sre/DbSetProcess.java

@@ -290,49 +290,24 @@ protected void doIt() {
         }
 
         // Build an Element Path for each database.  This will be use to divide the work.
-//        int threadCount = getParent().getConfig().getParallelism();
-
-
-//        List<ReportCounter> counters = new ArrayList<ReportCounter>();
         int i = 0;
         counterGroup.addAndGetTaskState(TaskState.CONSTRUCTED, dbs.length);
         for (String database : dbs) {
             DbPaths paths = new DbPaths(database, this);
             paths.setCommandChecks(this.getCommandChecks());
             paths.setSkipCommandCheck(this.getSkipCommandCheck());
             paths.setCounterGroup(counterGroup);
-//            paths.error = this.error;
-//            paths.success = this.success;
             if (paths.init()) {
-//                paths.setStatus(CONSTRUCTED);
-//                pathsList.add(paths);
             } else {
                 throw new RuntimeException("Issue establishing a connection to HDFS.  " +
                         "Check credentials(kerberos), configs(/etc/hadoop/conf), " +
                         "and/or availability of the HDFS service. " +
                         "Can you run an 'hdfs' cli command successfully?");
             }
-
-//            paths.setStatus(WAITING);
-//            counters.add(paths.getCounter());
             i++;
             LOG.info(getDisplayName() + " adding paths for db: " + database);
-//            getParent().getReporter().addCounter(getId() + ":" + getDisplayName(), paths.getCounter());
             // Add Runnable to Main ThreadPool
             Future<String> sf = getParent().getTaskThreadPool().submit(paths);
-//            ScheduledFuture<String> sf = getParent().getThreadPool().schedule(paths, 10, MILLISECONDS);
-//            getParent().addProcess(sf);
-//            try {s
-//                while (getParent().getProcessThreads().size() > 100) {
-//                    try {
-//                        Thread.sleep(1000);
-//                    } catch (InterruptedException ie) {
-//                        //
-//                    }
-//                }
-//            } catch (ConcurrentModificationException cme) {
-//                //
-//            }
         }
 
         if (getCommandChecks() == null) {