Package org.apache.hadoop.chukwa.datacollection.connector.http

Examples of org.apache.hadoop.chukwa.datacollection.connector.http.HttpConnector.shutdown()

86
87
88
89
90
91
92
93
94
95
96
    String[] stat = agent.getAdaptorList().get("adaptor_constSend").split(" ");
    long bytesCommitted = Long.valueOf(stat[stat.length -1]);
    assertTrue(bytesCommitted > 0);
    agent.shutdown();
    conn.shutdown();
    Thread.sleep(2000); //for collectors to shut down
    collector2_s.stop();
    Thread.sleep(2000); //for collectors to shut down
   
    checkDirs(conf, conf.get(CommitCheckServlet.SCANPATHS_OPT));
View Full Code Here
49
50
51
52
53
54
55
56
57
58
59
      tmpOutput.delete();
      assertFalse(failed);
      System.out.println("done");
      agent.shutdown();
      connector.shutdown();
      Thread.sleep(2000);
    } catch (Exception e) {
      e.printStackTrace();
    }
  }
View Full Code Here
59
60
61
62
63
64
65
66
67
68
69
    System.out.println(resets + " resets");
    assertTrue(resets > 0);
   
    agent.shutdown();
    collectorServ.stop();
    conn.shutdown();
    Thread.sleep(5000); //for collector to shut down
   
    long dups = TestFailedCollectorAck.checkDirs(conf, conf.get(SeqFileWriter.OUTPUT_DIR_OPT));
    assertTrue(dups > 0);
    TestDirTailingAdaptor.nukeDirContents(new File(outputDirectory));
View Full Code Here
242
243
244
245
246
247
248
249
250
251
252
      AsyncAckSender sender = (AsyncAckSender)conn.getSender();
      assertEquals(0, sender.adaptorReset.getResetCount());
     
      agent.shutdown();
      collectorServ.stop();
      conn.shutdown();
      Thread.sleep(5000); //for collector to shut down
      TestDirTailingAdaptor.nukeDirContents(new File(outputDirectory));
     
    } catch (Exception e) {
      e.printStackTrace();
View Full Code Here
69
70
71
72
73
74
75
76
77
78
79
    String[] stat = agent.getAdaptorList().get("constSend").split(" ");
    long bytesCommitted = Long.valueOf(stat[stat.length -1]);
    assertTrue(bytesCommitted > 0);
    agent.shutdown();
    conn.shutdown();
    Thread.sleep(2000); //for collectors to shut down
    collector2_s.stop();
    Thread.sleep(2000); //for collectors to shut down
   
    checkDirs(conf, conf.get(CommitCheckServlet.SCANPATHS_OPT));
View Full Code Here
42
43
44
45
46
47
48
49
50
51
52
    System.out.println(resets + " resets");
    assertTrue(resets > 0);
   
    agent.shutdown();
    collectorServ.stop();
    conn.shutdown();
    Thread.sleep(5000); //for collector to shut down
   
    long dups = TestFailedCollectorAck.checkDirs(conf, conf.get(SeqFileWriter.OUTPUT_DIR_OPT));
    assertTrue(dups > 0);
    TestDirTailingAdaptor.nukeDirContents(new File(outputDirectory));
View Full Code Here
238
239
240
241
242
243
244
245
246
247
248
      AsyncAckSender sender = (AsyncAckSender)conn.getSender();
      assertEquals(0, sender.adaptorReset.getResetCount());
     
      agent.shutdown();
      collectorServ.stop();
      conn.shutdown();
      Thread.sleep(5000); //for collector to shut down
      TestDirTailingAdaptor.nukeDirContents(new File(outputDirectory));
     
    } catch (Exception e) {
      e.printStackTrace();
View Full Code Here
51
52
53
54
55
56
57
58
59
60
61
     
      tmpOutput.delete();
      assertFalse(failed);
      System.out.println("done");
      agent.shutdown();
      connector.shutdown();
    } catch(Exception e) {
      e.printStackTrace();
    }
  }
View Full Code Here
86
87
88
89
90
91
92
93
94
95
96
    String[] stat = agent.getAdaptorList().get("constSend").split(" ");
    long bytesCommitted = Long.valueOf(stat[stat.length -1]);
    assertTrue(bytesCommitted > 0);
    agent.shutdown();
    conn.shutdown();
    Thread.sleep(2000); //for collectors to shut down
    collector2_s.stop();
    Thread.sleep(2000); //for collectors to shut down
   
    checkDirs(conf, conf.get(CommitCheckServlet.SCANPATHS_OPT));
View Full Code Here
59
60
61
62
63
64
65
66
67
68
69
    System.out.println(resets + " resets");
    assertTrue(resets > 0);
   
    agent.shutdown();
    collectorServ.stop();
    conn.shutdown();
    Thread.sleep(5000); //for collector to shut down
   
    long dups = TestFailedCollectorAck.checkDirs(conf, conf.get(SeqFileWriter.OUTPUT_DIR_OPT));
    assertTrue(dups > 0);
    TestDirTailingAdaptor.nukeDirContents(new File(outputDirectory));
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.