"testApp1", "testFlow1", "testFlowlet1", "", ""));
generateLogs(new UserServiceLoggingContext(TEST_NAMESPACE,
"testApp4", "testService1", "test1", "", ""));
}
@Override
<BUG>public void getLogNext(LoggingContext loggingContext, LogOffset fromOffset, int maxEvents, Filter filter,
</BUG>
Callback callback) {
<BUG>if (fromOffset.getKafkaOffset() < 0) {

getLogPrev(loggingContext, fromOffset, maxEvents, filter, callback);
</BUG>
return;

"testApp1", "testFlow1", "testFlowlet1", "", ""));
generateLogs(new MapReduceLoggingContext(Constants.DEFAULT_NAMESPACE,
"testApp3", "testMapReduce1", "", null));
generateLogs(new UserServiceLoggingContext(Constants.DEFAULT_NAMESPACE,
"testApp4", "testService1", "test1", "", ""));
generateLogs(new MapReduceLoggingContext(TEST_NAMESPACE,
"testTemplate1", "testMapReduce1", "", "testAdapter1"));
generateLogs(new FlowletLoggingContext(TEST_NAMESPACE,
"testApp1", "testFlow1", "testFlowlet1", "", ""));
generateLogs(new UserServiceLoggingContext(TEST_NAMESPACE,
"testApp4", "testService1", "test1", "", ""));
