This is an automated email from the ASF dual-hosted git repository. rong pushed a commit to branch fix-pipe-compressor in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 7a78e173c644af82a46642aa6b5ef65eec5b4537 Author: Steve Yurong Su <[email protected]> AuthorDate: Mon May 20 20:04:07 2024 +0800 Update DataRegionWatermarkInjector.java --- .../iotdb/db/pipe/extractor/dataregion/DataRegionWatermarkInjector.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/extractor/dataregion/DataRegionWatermarkInjector.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/extractor/dataregion/DataRegionWatermarkInjector.java index 5d8bbf615ae..a8d95d44810 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/extractor/dataregion/DataRegionWatermarkInjector.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/extractor/dataregion/DataRegionWatermarkInjector.java @@ -28,7 +28,7 @@ public class DataRegionWatermarkInjector { private static final Logger LOGGER = LoggerFactory.getLogger(DataRegionWatermarkInjector.class); - public static final long MIN_INJECTION_INTERVAL_IN_MS = 30 * 1000; // 30s + public static final long MIN_INJECTION_INTERVAL_IN_MS = 30 * 1000L; // 30s private final int regionId;
