This is an automated email from the ASF dual-hosted git repository.
Caideyipi pushed a commit to branch cve-13
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/cve-13 by this push:
new cb62b4241a7 [To dev/1.3] Pipe: Upgraded bouncy castle && Added logs
for pipe tsFile parser (#17504)
cb62b4241a7 is described below
commit cb62b4241a7f35238ca6b3a091657854b0543969
Author: Caideyipi <[email protected]>
AuthorDate: Mon Apr 20 15:39:51 2026 +0800
[To dev/1.3] Pipe: Upgraded bouncy castle && Added logs for pipe tsFile
parser (#17504)
---
.../tsfile/container/TsFileInsertionDataContainer.java | 17 ++++++++++++++++-
.../query/TsFileInsertionQueryDataContainer.java | 11 ++++++++++-
.../scan/TsFileInsertionScanDataContainer.java | 11 ++++++++++-
pom.xml | 2 +-
4 files changed, 37 insertions(+), 4 deletions(-)
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/container/TsFileInsertionDataContainer.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/container/TsFileInsertionDataContainer.java
index 279996690ff..2fe891ea2fb 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/container/TsFileInsertionDataContainer.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/container/TsFileInsertionDataContainer.java
@@ -24,6 +24,7 @@ import
org.apache.iotdb.commons.pipe.agent.task.meta.PipeTaskMeta;
import org.apache.iotdb.commons.pipe.datastructure.pattern.PipePattern;
import org.apache.iotdb.commons.pipe.event.EnrichedEvent;
import org.apache.iotdb.db.conf.IoTDBDescriptor;
+import
org.apache.iotdb.db.pipe.event.common.tsfile.parser.table.TsFileInsertionEventTableParser;
import org.apache.iotdb.db.pipe.metric.overview.PipeTsFileToTabletsMetrics;
import org.apache.iotdb.db.pipe.resource.PipeDataNodeResourceManager;
import org.apache.iotdb.db.pipe.resource.memory.PipeMemoryBlock;
@@ -39,6 +40,7 @@ import org.apache.tsfile.write.record.Tablet;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+import java.io.File;
import java.io.IOException;
public abstract class TsFileInsertionDataContainer implements AutoCloseable {
@@ -69,13 +71,15 @@ public abstract class TsFileInsertionDataContainer
implements AutoCloseable {
protected Iterable<TabletInsertionEvent> tabletInsertionIterable;
protected TsFileInsertionDataContainer(
+ final File tsFile,
final String pipeName,
final long creationTime,
final PipePattern pattern,
final long startTime,
final long endTime,
final PipeTaskMeta pipeTaskMeta,
- final EnrichedEvent sourceEvent) {
+ final EnrichedEvent sourceEvent,
+ final boolean isWithMod) {
this.pipeName = pipeName;
this.creationTime = creationTime;
@@ -93,6 +97,17 @@ public abstract class TsFileInsertionDataContainer
implements AutoCloseable {
PipeDataNodeResourceManager.memory()
.forceAllocateForTabletWithRetry(
IoTDBDescriptor.getInstance().getConfig().getPipeDataStructureTabletSizeInBytes());
+
+ LOGGER.info(
+ "TsFile {} has initialized {}, pipeName: {}, creation time: {},
pattern: {}, startTime: {}, endTime: {}, withMod: {}",
+ tsFile,
+ getClass().getSimpleName(),
+ pipeName,
+ creationTime,
+ this instanceof TsFileInsertionEventTableParser ? tablePattern :
treePattern,
+ startTime,
+ endTime,
+ isWithMod);
}
/**
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/container/query/TsFileInsertionQueryDataContainer.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/container/query/TsFileInsertionQueryDataContainer.java
index 15732fd0e8d..4353e4984a2 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/container/query/TsFileInsertionQueryDataContainer.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/container/query/TsFileInsertionQueryDataContainer.java
@@ -114,7 +114,16 @@ public class TsFileInsertionQueryDataContainer extends
TsFileInsertionDataContai
final Map<IDeviceID, Boolean> deviceIsAlignedMap,
final boolean isWithMod)
throws IOException {
- super(pipeName, creationTime, pattern, startTime, endTime, pipeTaskMeta,
sourceEvent);
+ super(
+ tsFile,
+ pipeName,
+ creationTime,
+ pattern,
+ startTime,
+ endTime,
+ pipeTaskMeta,
+ sourceEvent,
+ isWithMod);
try {
currentModifications =
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/container/scan/TsFileInsertionScanDataContainer.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/container/scan/TsFileInsertionScanDataContainer.java
index 271bc317d0f..8ed9bdcd662 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/container/scan/TsFileInsertionScanDataContainer.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/container/scan/TsFileInsertionScanDataContainer.java
@@ -116,7 +116,16 @@ public class TsFileInsertionScanDataContainer extends
TsFileInsertionDataContain
final EnrichedEvent sourceEvent,
final boolean isWithMod)
throws IOException {
- super(pipeName, creationTime, pattern, startTime, endTime, pipeTaskMeta,
sourceEvent);
+ super(
+ tsFile,
+ pipeName,
+ creationTime,
+ pattern,
+ startTime,
+ endTime,
+ pipeTaskMeta,
+ sourceEvent,
+ isWithMod);
this.startTime = startTime;
this.endTime = endTime;
diff --git a/pom.xml b/pom.xml
index 35c7eeb481e..294a1231e35 100644
--- a/pom.xml
+++ b/pom.xml
@@ -60,7 +60,7 @@
<argLine/>
<awaitility.version>4.2.0</awaitility.version>
<boost.include.dir/>
- <bouncycastle.version>1.81</bouncycastle.version>
+ <bouncycastle.version>1.84</bouncycastle.version>
<!-- This was the last version to support Java 8 -->
<caffeine.version>2.9.3</caffeine.version>
<cglib.version>3.3.0</cglib.version>
