p78659104
/
ossean
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

gather removed some log output

This commit is contained in:
zhanyun 2016-04-11 22:00:01 +08:00
parent 25bca51ab7
commit 89a49a96cc
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
gather_program/src/main/java/org/ossean/gather/process/GatherThread.java
View File

@ -73,7 +73,7 @@ public class GatherThread implements Runnable {
@Override @Override
public void run() { public void run() {
long start = System.currentTimeMillis(); // long start = System.currentTimeMillis();
Thread.currentThread().setName(sourceTableName); Thread.currentThread().setName(sourceTableName);
idsIncrement = conf.getIdsIncrement(); idsIncrement = conf.getIdsIncrement();
idsBegin = readPointer(conf.getPointerTableName(), sourceTableName, idsBegin = readPointer(conf.getPointerTableName(), sourceTableName,
@ -92,8 +92,8 @@ public class GatherThread implements Runnable {
} }
} }
GatherProcess.gatherState.put(sourceTableName, false); GatherProcess.gatherState.put(sourceTableName, false);
long end = System.currentTimeMillis(); // long end = System.currentTimeMillis();
logger.info((end - start) / 6000); // logger.info((end - start) / 6000);
} }
public void handleBatchData(int beginId, int endId, Configure conf) { public void handleBatchData(int beginId, int endId, Configure conf) {