9899100101102103104105106107108
source.start(); Thread.sleep(5000); source.stop(); sinkRunner.stop(); sink.stop(); } @Test public void testCarrotDateFormatBug() throws Exception { SimpleDateFormat formatterFrom = new SimpleDateFormat("EEE MMM dd HH:mm:ss Z yyyy");