This commit is contained in:
J-huhan 2025-04-10 16:23:00 +08:00 committed by GitHub
commit c99a47108c
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194

View File

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