This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch rc/1.2.2
in repository https://gitbox.apache.org/repos/asf/iotdb.git
discard 19d056f9593 Revert "[To rel/1.2][IOTDB-6143] Pipe: Support
PipeConnector subtasks with the same parameters concurrently scheduling
(#11185)"
discard 34ab26e6c95 Revert "[To rel/1.2][ISSUE-11199] Pipe: fix NPE when
casting from null values in InsertRowNode deserialization (#11200) (#11205)"
discard 4d7274e9dd3 Revert "[To rel/1.2] Pipe: fix NPE in
PipeEnrichedInsertBaseStatement#isQuery when analyzing statement in metadata
mismatch scenarios (#11203) (#11206)"
discard b0e0a1d4d3a Revert "Pipe: fix file handle leak when processing with
extractor.pattern (#11209) (#11213)"
new 76c16ca85d2 Revert "Revert "Pipe: Improve performance for 10000+ pipes
(#11021) (#11051)""
new 0b16cffb31b Revert "[To rel/1.2] Pipe: fix NPE in
PipeEnrichedInsertBaseStatement#isQuery when analyzing statement in metadata
mismatch scenarios (#11203) (#11206)"
new e43c94651f4 Revert "[To rel/1.2][ISSUE-11199] Pipe: fix NPE when
casting from null values in InsertRowNode deserialization (#11200) (#11205)"
new 3aedfafe89a Revert "[To rel/1.2][IOTDB-6143] Pipe: Support
PipeConnector subtasks with the same parameters concurrently scheduling
(#11185)"
new c688e3dbdc6 Revert "[IOTDB-6159] Pipe: Supported E-language payload in
air gap connector/receiver (#11136) (#11167)"
new 72bf2a8f6c5 Revert "[IOTDB-6142] Pipe: Implemented IoTDBOpcUaConnector
to enable transfer using Opc Ua protocol (#11081)"
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (19d056f9593)
\
N -- N -- N refs/heads/rc/1.2.2 (72bf2a8f6c5)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 6 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/pipe/api/PipeConnector.java | 10 +-
.../org/apache/iotdb/pipe/api/PipeProcessor.java | 10 +-
.../event/dml/insertion/TsFileInsertionEvent.java | 2 +-
iotdb-core/datanode/pom.xml | 5 -
.../iotdb/db/pipe/agent/task/PipeTaskAgent.java | 9 +-
.../config/constant/PipeConnectorConstant.java | 10 -
.../payload/airgap/AirGapELanguageConstant.java | 34 ---
.../payload/airgap/AirGapOneByteResponse.java | 4 -
.../protocol/airgap/IoTDBAirGapConnector.java | 29 +--
.../connector/protocol/opcua/OpcUaConnector.java | 246 ------------------
.../protocol/opcua/OpcUaKeyStoreLoader.java | 120 ---------
.../protocol/opcua/OpcUaServerBuilder.java | 287 ---------------------
.../thrift/async/IoTDBThriftAsyncConnector.java | 8 +-
.../websocket/WebSocketConnectorServer.java | 1 -
...ocketConnector.java => WebsocketConnector.java} | 17 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 15 +-
.../tsfile/TsFileInsertionDataContainer.java | 1 +
.../PipeHistoricalDataRegionTsFileExtractor.java | 36 ++-
.../pipe/receiver/airgap/IoTDBAirGapReceiver.java | 58 ++---
.../resource/tsfile/PipeTsFileResourceManager.java | 7 +-
.../connector/PipeConnectorSubtaskManager.java | 3 -
.../impl/DataNodeInternalRPCServiceImpl.java | 4 +-
.../plan/planner/plan/node/write/InsertNode.java | 1 -
.../pipe/plugin/builtin/BuiltinPipePlugin.java | 2 -
.../plugin/builtin/connector/OpcUaConnector.java | 28 --
pom.xml | 2 -
26 files changed, 112 insertions(+), 837 deletions(-)
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/airgap/AirGapELanguageConstant.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/opcua/OpcUaConnector.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/opcua/OpcUaKeyStoreLoader.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/opcua/OpcUaServerBuilder.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/websocket/{WebSocketConnector.java
=> WebsocketConnector.java} (91%)
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/OpcUaConnector.java
