This is an automated email from the ASF dual-hosted git repository.
hui pushed a change to branch lmh/intoOperator
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 9a2cf1c429 modify IT to BeforeClass & AfterClass
add 6101e132d6 [IOTDB-4293] BufferedPipeDataQueue supports discontinuous
serialNumber (#7664)
add 083b241b84 Integrate dockerfile from rel/0.12, rel/0.13 (#7701)
add bcc9c3be79 [IOTDB-4712]Add size limit of trigger jar when create
Trigger on ConfigNode (#7684)
add d913886a80 [IOTDB-4717] Refactor UDFRegistrationService for new
Cluster (#7700)
add 22e0c55a27 Change previous IT from server module to integration-test
(#7705)
add e9a5850eb4 Use 1c1d docker to run python and influxdb protocal IT
(#7703)
add 943d67c915 Merge remote-tracking branch 'origin/master' into
lmh/intoOperator
No new revisions were added by this update.
Summary of changes:
.dockerignore | 1 +
.github/workflows/client-python.yml | 4 +-
.github/workflows/influxdb-protocol.yml | 2 +-
client-py/requirements.txt | 4 +-
client-py/tests/test_dataframe.py | 4 +-
.../write/procedure/UpdateProcedurePlan.java | 13 +
.../iotdb/confignode/manager/ProcedureManager.java | 29 +-
.../iotdb/confignode/manager/TriggerManager.java | 2 +
.../iotdb/confignode/persistence/UDFInfo.java | 16 +-
.../iotdb/confignode/service/ConfigNode.java | 2 -
.../request/ConfigPhysicalPlanSerDeTest.java | 2 +
.../confignode/persistence/TriggerInfoTest.java | 3 +
.../procedure/impl/CreateTriggerProcedureTest.java | 3 +
.../src/main/DockerCompose/start-1c1d.sh | 6 +-
docker/src/main/Dockerfile-0.10.0 | 39 --
docker/src/main/Dockerfile-0.11.1 | 39 --
docker/src/main/Dockerfile-0.11.2 | 41 --
docker/src/main/Dockerfile-0.11.3 | 41 --
docker/src/main/Dockerfile-0.12.1-cluster | 53 ---
...le-0.12.0-cluster => Dockerfile-0.12.6-cluster} | 10 +-
...le-0.12.2-grafana => Dockerfile-0.12.6-grafana} | 10 +-
...ckerfile-0.12.0-node => Dockerfile-0.12.6-node} | 10 +-
...le-0.12.2-cluster => Dockerfile-0.13.0-cluster} | 10 +-
...grafana => Dockerfile-0.13.3-grafana-connector} | 20 +-
...ckerfile-0.12.1-node => Dockerfile-0.13.3-node} | 10 +-
...-node => Dockerfile-0.13.3-node-multi-platform} | 12 +-
docker/src/main/Dockerfile-0.9.0 | 41 --
.../main/{Dockerfile-0.11.0 => Dockerfile-1c1d} | 35 +-
...le-single-influxdb => Dockerfile-1c1d-influxdb} | 17 +-
docs/UserGuide/Alert/Alerting.md | 1 -
docs/zh/UserGuide/Alert/Alerting.md | 6 +-
.../iotdb/trigger/ClusterAlertingExample.java | 2 +-
integration-test/import-control.xml | 4 +
.../java/org/apache/iotdb/it/env/AbstractEnv.java | 6 +
.../org/apache/iotdb/it/env/DataNodeWrapper.java | 8 +
.../java/org/apache/iotdb/it/env/MppConfig.java | 30 ++
.../org/apache/iotdb/it/env/RemoteServerEnv.java | 5 +
.../org/apache/iotdb/itbase/env/BaseConfig.java | 40 ++
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 2 +
.../org/apache/iotdb/db/it/env/StandaloneEnv.java | 5 +
.../iotdb/db/it/env/StandaloneEnvConfig.java | 55 +++
.../apache/iotdb/db/it/mqtt/IoTDBMQTTSinkIT.java | 68 +--
.../iotdb/db/it/udf/IoTDBUDFManagementIT.java | 8 +-
.../iotdb/db/it/watermark/IoTDBWatermarkIT.java | 179 +++----
.../apache/iotdb/commons/conf/IoTDBConstant.java | 3 +
.../apache/iotdb/commons/service/ServiceType.java | 1 -
.../iotdb/commons/trigger/TriggerInformation.java | 3 +-
...trationInformation.java => UDFInformation.java} | 29 +-
.../org/apache/iotdb/commons/udf/UDFTable.java | 36 +-
.../commons/udf/service/UDFExecutableManager.java | 8 +-
.../commons/udf/service/UDFManagementService.java | 280 +++++++++++
.../udf/service/UDFRegistrationService.java | 513 ---------------------
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 2 +-
.../operator/process/TransformOperator.java | 6 +-
.../executor/StandaloneConfigTaskExecutor.java | 9 +-
.../config/metadata/ShowFunctionsTask.java | 7 +-
.../mpp/transformation/dag/udf/UDTFExecutor.java | 4 +-
.../dag/udf/UDTFInformationInferrer.java | 4 +-
.../iotdb/db/protocol/mqtt/PublishHandler.java | 4 -
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 18 +-
.../apache/iotdb/db/query/dataset/UDTFDataSet.java | 6 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 5 -
.../java/org/apache/iotdb/db/service/IoTDB.java | 8 -
.../java/org/apache/iotdb/db/service/NewIoTDB.java | 8 -
.../impl/DataNodeInternalRPCServiceImpl.java | 15 +-
.../sync/pipedata/queue/BufferedPipeDataQueue.java | 70 +--
.../iotdb/db/protocol/mqtt/PublishHandlerTest.java | 132 ------
.../iotdb/db/qp/physical/PhysicalPlanTest.java | 27 +-
.../apache/iotdb/db/sink/LocalIoTDBSinkTest.java | 218 ---------
.../sync/pipedata/BufferedPipeDataQueueTest.java | 95 ++++
.../apache/iotdb/db/utils/EnvironmentUtils.java | 10 +-
...nException.java => UDFManagementException.java} | 6 +-
72 files changed, 932 insertions(+), 1493 deletions(-)
copy
server/src/main/resources/META-INF/services/org.apache.iotdb.db.protocol.mqtt.PayloadFormatter
=> docker/src/main/DockerCompose/start-1c1d.sh (88%)
mode change 100644 => 100755
delete mode 100644 docker/src/main/Dockerfile-0.10.0
delete mode 100644 docker/src/main/Dockerfile-0.11.1
delete mode 100644 docker/src/main/Dockerfile-0.11.2
delete mode 100644 docker/src/main/Dockerfile-0.11.3
delete mode 100644 docker/src/main/Dockerfile-0.12.1-cluster
rename docker/src/main/{Dockerfile-0.12.0-cluster =>
Dockerfile-0.12.6-cluster} (85%)
copy docker/src/main/{Dockerfile-0.12.2-grafana => Dockerfile-0.12.6-grafana}
(83%)
rename docker/src/main/{Dockerfile-0.12.0-node => Dockerfile-0.12.6-node} (83%)
rename docker/src/main/{Dockerfile-0.12.2-cluster =>
Dockerfile-0.13.0-cluster} (85%)
rename docker/src/main/{Dockerfile-0.12.2-grafana =>
Dockerfile-0.13.3-grafana-connector} (66%)
rename docker/src/main/{Dockerfile-0.12.1-node => Dockerfile-0.13.3-node} (83%)
rename docker/src/main/{Dockerfile-0.12.2-node =>
Dockerfile-0.13.3-node-multi-platform} (80%)
delete mode 100644 docker/src/main/Dockerfile-0.9.0
rename docker/src/main/{Dockerfile-0.11.0 => Dockerfile-1c1d} (57%)
copy docker/src/main/{Dockerfile-single-influxdb => Dockerfile-1c1d-influxdb}
(77%)
rename server/src/test/java/org/apache/iotdb/db/sink/MQTTSinkTest.java =>
integration-test/src/test/java/org/apache/iotdb/db/it/mqtt/IoTDBMQTTSinkIT.java
(76%)
rename server/src/test/java/org/apache/iotdb/db/tools/IoTDBWatermarkTest.java
=>
integration-test/src/test/java/org/apache/iotdb/db/it/watermark/IoTDBWatermarkIT.java
(53%)
rename
node-commons/src/main/java/org/apache/iotdb/commons/udf/{service/UDFRegistrationInformation.java
=> UDFInformation.java} (79%)
copy session/src/main/java/org/apache/iotdb/session/template/TemplateNode.java
=> node-commons/src/main/java/org/apache/iotdb/commons/udf/UDFTable.java (52%)
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/udf/service/UDFManagementService.java
delete mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/udf/service/UDFRegistrationService.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/protocol/mqtt/PublishHandlerTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/sink/LocalIoTDBSinkTest.java
rename
udf-api/src/main/java/org/apache/iotdb/udf/api/exception/{UDFRegistrationException.java
=> UDFManagementException.java} (83%)
