This is an automated email from the ASF dual-hosted git repository.
jt2594838 pushed a commit to branch dev/1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/dev/1.3 by this push:
new 4588b8d27a4 [To dev/1.3] Pipe: Upgraded bouncy castle && Added logs
for pipe tsFile parser (#17504) (#17523)
4588b8d27a4 is described below
commit 4588b8d27a414fde21f6c58d3e4534866c06bb96
Author: Caideyipi <[email protected]>
AuthorDate: Tue Apr 21 16:46:56 2026 +0800
[To dev/1.3] Pipe: Upgraded bouncy castle && Added logs for pipe tsFile
parser (#17504) (#17523)
* [To dev/1.3] Pipe: Upgraded bouncy castle && Added logs for pipe tsFile
parser (#17504)
* fixed
---
.../tsfile/container/TsFileInsertionDataContainer.java | 16 +++++++++++++++-
.../query/TsFileInsertionQueryDataContainer.java | 11 ++++++++++-
.../container/scan/TsFileInsertionScanDataContainer.java | 11 ++++++++++-
pom.xml | 2 +-
4 files changed, 36 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..f335cff1035 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
@@ -39,6 +39,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 +70,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 +96,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,
+ pattern,
+ 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>
