more logs

This commit is contained in:
fjy 2013-12-06 09:57:07 -08:00
parent 986223a49d
commit 90aa9eca47
1 changed files with 1 additions and 1 deletions

View File

@ -74,7 +74,7 @@ public class FlushingPlumber extends RealtimePlumber
@Override @Override
public void startJob() public void startJob()
{ {
log.info("Starting job"); log.info("Starting job for %s", getSchema().getDataSource());
computeBaseDir(getSchema()).mkdirs(); computeBaseDir(getSchema()).mkdirs();
initializeExecutors(); initializeExecutors();