optimize code

This commit is contained in:
胡晗 2020-08-13 16:24:24 +08:00
parent aedc679c73
commit 1282ab2c8d

View File

@ -172,9 +172,8 @@ public class CommonRdbmsReader {
public void startRead(Configuration readerSliceConfig,
RecordSender recordSender,
TaskPluginCollector taskPluginCollector, int fetchSize) {
String querySql = readerSliceConfig.getString(Key.QUERY_SQL);
String table = readerSliceConfig.getString(Key.TABLE);
querySql = querySql.replaceAll(Constant.TABLE_NAME_PLACEHOLDER, table);
String querySql = readerSliceConfig.getString(Key.QUERY_SQL).replaceAll(Constant.TABLE_NAME_PLACEHOLDER, table);
PerfTrace.getInstance().addTaskDetails(taskId, table + "," + basicMsg);