Commit Graph

12746 Commits

Author SHA1 Message Date
Caideyipi 5b3cd27d5e
Load: Added the missing logic for tsFile conversion disable's cherry-picking (#16024)
* Update TreeSchemaAutoCreatorAndVerifier.java

* Update LoadTsFileTableSchemaCache.java
2025-07-25 10:28:04 +08:00
Yongzao 441f85183a
[AINode] Update AINode wrapper (#16028) 2025-07-24 21:32:47 +08:00
shuwenwei 004b1bff0f
Set global time filter before analyze last query 2025-07-24 21:05:37 +08:00
Yongzao d2ee52ee14
[AINode] Remove remove-ainode scripts (#16023) 2025-07-24 18:24:39 +08:00
Caideyipi 08ab2c9dcd
Pipe: Optimized the degrading logger & Deleted useless UT & Copied some historical filter logic from dev/1.3 (#16019)
* logger

* fix-ut

* Update PipeHistoricalDataRegionTsFileAndDeletionExtractor.java
2025-07-23 18:58:38 +08:00
Caideyipi f616e3441c
Pipe: Exclude the tsFiles / insertNodes from transfer time metric which have not be sent (#16015) 2025-07-23 16:55:40 +08:00
Caideyipi 376162a3ad
Pipe: Fixed the hard-link lock problem & Some pipe CIs on master (#16006)
* Update IoTDBPipePermissionIT.java

* refacotr

* revert=pom

* fix-lock
2025-07-23 16:11:13 +08:00
FearfulTomcat27 eab1b825da
fix: Ensure correct evaluation order in BinaryColumnTransformer 2025-07-23 15:20:55 +08:00
Caideyipi 10d288d9d8
Pipe: Removed the old useless loopback detection logic (#16007)
* remove-useless

* fix
2025-07-23 15:13:11 +08:00
Yongzao f1870cb9b0
[AINode] Limit max inference length (#15982) 2025-07-23 12:05:42 +08:00
Summer 1d3a35e76e
Explicitly specify the JVM character encoding as UTF-8 in the shell script (#15961) 2025-07-23 11:13:44 +08:00
Weihao Li 2c6e00f1f1
Support extract value filter push down 2025-07-23 09:10:59 +08:00
Jackie Tien 9fb66af408
Avoid potential deadlock in TableFunctionLeafOperator 2025-07-22 19:49:57 +08:00
Caideyipi 4f9e75f944
Pipe: Fixed the renaming view's concurrency problem 2025-07-22 18:31:50 +08:00
Caideyipi 37ce6d17dd
Pipe: Do not transfer historical tsFiles when restarts in realtime-only mode (#15996) 2025-07-22 18:19:28 +08:00
Steve Yurong Su 7214e1f367
Pipe: Report progress index for filter-outed insertion events in realtime extractors (#15975)
* fix

* fix
2025-07-22 18:08:54 +08:00
Steve Yurong Su de05c67c51
Pipe: Handle existing hardlink in createHardLink method (#15998)
Adds logic to check if a hardlink already exists when creating a hardlink. If the existing file matches the source (by MD5), a warning is logged and creation is skipped. If not, the existing file is deleted and creation is retried, with error handling and logging for failures.
2025-07-22 17:34:38 +08:00
Jiang Tian 1d2f36ec00
Fix that stopping ratis may get stuck due to closed FlushManager (#15992) 2025-07-22 15:47:51 +08:00
CloudWise-Lukemiao fbc28c6e27
Fixed issues in the rest service module: BLOB, DATE, table model parameters, and added statistical delay monitoring items to FastLastQuery. (#15917)
* The following issues have been fixed:
1、When querying BLOB data type through the /rest/v2/query interface, the returned results display garbled characters.
2、For the DATE data type, it is recommended that the returned results be displayed with separators, such as: 2025-01-01.
3、Added statistical delay monitoring items to FastLastQuery.
4、Fixed the spelling error of the column_categories parameter in the insertTablet method of the table model.

* add it

* add it

* add it

* add it
2025-07-22 15:46:28 +08:00
Zhenyu Luo 0340423366
Pipe: Update the log of the heartbeat process reported by DN to CN (#15983) 2025-07-22 15:44:27 +08:00
Zhenyu Luo b9e7bd3aec
Load: Fixed the issue that the loading table model file failed under Tree Dialect Cli (#15942)
* Load: Fixed the issue that the loading table model file failed under Tree Dialect Cli

* add IT

* IT spotless
2025-07-22 14:12:21 +08:00
Zhenyu Luo 75d7f27fbd
Pipe: Reduce IoTDBAirGapConnector Handshake times (#15990) 2025-07-22 14:08:32 +08:00
Zhenyu Luo d34054dec5
Pipe: Fix the problem that a cluster crash in the multi-cluster receiving end causes all synchronization to be suspended (#15962)
* Pipe: Fix the problem that a cluster crash in the multi-cluster receiving end causes all synchronization to be suspended

* add IsEndPointAlive Function

* add IsEndPointAlive Function

* add IsEndPointAlive Function

* add pipeCheckSyncAllClientLiveTimeIntervalMs config

* fix

* fix

* fix

* fix
2025-07-22 10:40:30 +08:00
Caideyipi f076824eb0
Pipe: Fixed some errors in cherry-picking (#15984)
* Update TsFileProcessor.java

* fix-cp-2

* fix-fix

* Update PipeTsFileResourceManager.java

* Update PipeTsFileResourceManager.java
2025-07-22 09:34:19 +08:00
Yongzao 2288d7af39
[AINode] AINode docker compose file (#15987) 2025-07-21 23:31:10 +08:00
Yongzao 5bb17061bb
[AINode] Bump version to 2.0.6.dev (#15988) 2025-07-21 23:30:16 +08:00
Jackie Tien a804650a7f
Bump version to 2.0.6-SNAPSHOT 2025-07-21 17:00:08 +08:00
Yongzao 9bb8e9b58d
[AINode] Update AINode docker file and pytorch dependency (#15979) 2025-07-21 14:05:37 +08:00
Jackie Tien 3021737d9b
Avoid NPE in dealWithException of QueryExecution 2025-07-21 14:03:24 +08:00
Leo 24345354e4
[AINode] Accelerate memory efficiency of the multiprocessing architecture of inference_manager (#15956) 2025-07-21 09:30:21 +08:00
Weihao Li 67f63e09fa
Implement Extract expression in TableModel 2025-07-18 14:09:18 +08:00
Caideyipi c17ca38218
Pipe: Banned conversion IT (#15973) 2025-07-18 11:21:38 +08:00
shuwenwei 672e72dece
Fix the issue that querying exact device with some fuzzy filter may failed 2025-07-17 18:34:42 +08:00
Weihao Li 942e9118eb
Fix some Accumulator when process TIMESTAMP Type 2025-07-17 18:14:43 +08:00
Caideyipi 33eec34e83
Pipe: Fixed multiple bugs (#15964)
* [To dev/1.3] Fixed multiple bugs of pipe

* spotless

* Partial

* Update PipeInsertNodeTabletInsertionEvent.java

* partial

* partial

* fixed-partial

* part

* fix-compile

* Update TsFileInsertionEventParserTest.java

* Update IoTDBLoadTsFileIT.java

* Update IoTDBLoadTsFileIT.java
2025-07-17 18:12:01 +08:00
shuwenwei 589e07bd08
Fix the handling of empty value chunk when load splitting time partitions (#15966)
* Fix the handling of empty value chunk when load splitting time partitions

* modify test
2025-07-17 17:35:40 +08:00
Caideyipi 0f91e57a69
Pipe: Report progress index for filter-outed tsfile events in PipeHistoricalDataRegionTsFileAndDeletionExtractor (#15965)
* Update PipeHistoricalDataRegionTsFileAndDeletionExtractor.java

* report
2025-07-17 15:45:33 +08:00
Yongzao b5a7f078c4
[AINode] AINode Dockerfile (#15946) 2025-07-17 11:59:44 +08:00
Yongzao 800f95ddc3
[AINode] Modify heartbeat field (#15953) 2025-07-17 11:43:16 +08:00
Jackie Tien 2f07b0599f
Add beforeDestroy in TableFunctionLeafProcessor and TableFunctionDataProcessor 2025-07-17 10:55:15 +08:00
shuwenwei b1b0c0192a
Root FragmentInstance placement error may occur when querying table model aggregation with null data partition 2025-07-17 09:57:57 +08:00
dependabot[bot] d44c81cdbe
Bump io.projectreactor.netty:reactor-netty-http from 1.1.20 to 1.2.8 (#15958)
Bumps [io.projectreactor.netty:reactor-netty-http](https://github.com/reactor/reactor-netty) from 1.1.20 to 1.2.8.
- [Release notes](https://github.com/reactor/reactor-netty/releases)
- [Commits](https://github.com/reactor/reactor-netty/compare/v1.1.20...v1.2.8)

---
updated-dependencies:
- dependency-name: io.projectreactor.netty:reactor-netty-http
  dependency-version: 1.2.8
  dependency-type: direct:production
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
2025-07-17 09:28:33 +08:00
Caideyipi 905eb93633
Pipe: Added progressIndex reset function to the resource resetting script (#15955) 2025-07-16 18:59:40 +08:00
Zhenyu Luo 061d2de028
Pipe:Fix DataNodeShutdownHook waiting report logic and add capture history file log (#15952)
* Pipe:Fix DataNodeShutdownHook waiting report logic and add capture history file log

* fix
2025-07-16 14:35:22 +08:00
Steve Yurong Su 736cdf7a56
Pipe: Add a tool for validating and repairing isGeneratedByPipe mark in tsfile resources (#15934) (#15945) 2025-07-16 10:29:03 +08:00
Yongzao 393aba2074
[AINode] Support concurrent inference for Timer-Sundial (#15897) 2025-07-16 10:17:33 +08:00
Weihao Li 772bab4abe
Fix display of Blob type in last query 2025-07-16 06:41:26 +08:00
Caideyipi 08b4f8f5c0
Pipe: Fixed the ping-pong of certain realtime tsFiles 2025-07-15 23:49:59 +08:00
Jackie Tien f69347580e
Avoid NPE while stop DN (#15939) 2025-07-15 13:06:48 +08:00
Yongzao e139623037
[AINode] Remove AINode through SQL (#15937) 2025-07-15 13:06:30 +08:00