You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ro...@apache.org on 2023/10/13 07:56:37 UTC
[iotdb] branch hybrid-connot-unpin updated (6dd47bdd465 -> cb61dfd9e60)
This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch hybrid-connot-unpin
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 6dd47bdd465 refactor
new ba22e59bb89 Update PipeCronEventInjector.java
new cb61dfd9e60 Update CommonConfig.java
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../org/apache/iotdb/db/pipe/agent/runtime/PipeCronEventInjector.java | 2 +-
.../src/main/java/org/apache/iotdb/commons/conf/CommonConfig.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
[iotdb] 01/02: Update PipeCronEventInjector.java
Posted by ro...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
rong pushed a commit to branch hybrid-connot-unpin
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit ba22e59bb8964c962e2ab986f45a8e051ca90871
Author: Steve Yurong Su <ro...@apache.org>
AuthorDate: Fri Oct 13 15:52:38 2023 +0800
Update PipeCronEventInjector.java
---
.../org/apache/iotdb/db/pipe/agent/runtime/PipeCronEventInjector.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/runtime/PipeCronEventInjector.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/runtime/PipeCronEventInjector.java
index 8ec9798e187..2a9ae717247 100644
--- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/runtime/PipeCronEventInjector.java
+++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/runtime/PipeCronEventInjector.java
@@ -35,7 +35,7 @@ public class PipeCronEventInjector {
private static final Logger LOGGER = LoggerFactory.getLogger(PipeCronEventInjector.class);
- private static final int CRON_EVENT_INJECTOR_INTERVAL_SECONDS = 1;
+ private static final int CRON_EVENT_INJECTOR_INTERVAL_SECONDS = 30;
private static final ScheduledExecutorService CRON_EVENT_INJECTOR_EXECUTOR =
IoTDBThreadPoolFactory.newSingleThreadScheduledExecutor(
[iotdb] 02/02: Update CommonConfig.java
Posted by ro...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
rong pushed a commit to branch hybrid-connot-unpin
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit cb61dfd9e6045a7dd52c5df8d29860fd20b9525e
Author: Steve Yurong Su <ro...@apache.org>
AuthorDate: Fri Oct 13 15:56:26 2023 +0800
Update CommonConfig.java
---
.../src/main/java/org/apache/iotdb/commons/conf/CommonConfig.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/conf/CommonConfig.java b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/conf/CommonConfig.java
index e6bf01dff7f..25c751e83ed 100644
--- a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/conf/CommonConfig.java
+++ b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/conf/CommonConfig.java
@@ -189,7 +189,7 @@ public class CommonConfig {
private boolean pipeAirGapReceiverEnabled = false;
private int pipeAirGapReceiverPort = 9780;
- private int pipeMaxAllowedPendingTsFileEpochPerDataRegion = 3;
+ private int pipeMaxAllowedPendingTsFileEpochPerDataRegion = 1;
/** Whether to use persistent schema mode. */
private String schemaEngineMode = "Memory";