diff --git a/tdenginereader/src/main/java/com/alibaba/datax/plugin/reader/TDengineReader.java b/tdenginereader/src/main/java/com/alibaba/datax/plugin/reader/TDengineReader.java index 35c82bed..332ddf3a 100644 --- a/tdenginereader/src/main/java/com/alibaba/datax/plugin/reader/TDengineReader.java +++ b/tdenginereader/src/main/java/com/alibaba/datax/plugin/reader/TDengineReader.java @@ -193,6 +193,7 @@ public class TDengineReader extends Reader { sb.append(" and _c0 < '").append(endTime).append("'"); } String sql = sb.toString().trim(); + sqlList.add(sql); } } else { sqlList.addAll(querySql);