diff --git a/plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/reader/CommonRdbmsReader.java b/plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/reader/CommonRdbmsReader.java index a06b1afb..fe0e5577 100755 --- a/plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/reader/CommonRdbmsReader.java +++ b/plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/reader/CommonRdbmsReader.java @@ -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);