This is an automated email from the ASF dual-hosted git repository.
azexin pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git
from 50640ab4b7e Adjust checkstyle format (#25331)
add 26b0b04ed8b Refactor part of pipeline code by pmd results (#25333)
No new revisions were added by this update.
Summary of changes:
.../cdc/core/importer/SocketSinkImporter.java | 10 +---
.../pipeline/cdc/util/ColumnValueConvertUtils.java | 16 ++-----
.../yaml/YamlPipelineProcessConfiguration.java | 55 ----------------------
.../yaml/YamlPipelineReadConfiguration.java | 23 ---------
.../yaml/YamlPipelineWriteConfiguration.java | 21 ---------
.../AbstractDataConsistencyCalculateAlgorithm.java | 3 +-
...RC32MatchDataConsistencyCalculateAlgorithm.java | 3 +-
...DataMatchDataConsistencyCalculateAlgorithm.java | 3 +-
.../core/exception/PipelineInternalException.java | 14 +++---
.../data/pipeline/core/execute/ExecuteEngine.java | 25 +++++-----
.../memory/MultiplexMemoryPipelineChannel.java | 2 +-
.../memory/SimpleMemoryPipelineChannel.java | 9 ++--
.../pipeline/core/job/AbstractPipelineJob.java | 3 +-
.../StandardPipelineTableMetaDataLoader.java | 3 +-
.../metadata/node/PipelineMetaDataNodeWatcher.java | 13 +----
.../pipeline/mysql/ingest/client/MySQLClient.java | 7 +--
.../netty/MySQLBinlogEventPacketDecoder.java | 3 +-
.../ingest/client/netty/MySQLNegotiateHandler.java | 3 +-
.../ingest/wal/decode/MppdbDecodingPlugin.java | 3 +-
.../ingest/PostgreSQLPositionInitializer.java | 3 +-
.../migration/api/impl/MigrationJobAPI.java | 12 ++---
21 files changed, 55 insertions(+), 179 deletions(-)
copy
infra/util/src/main/java/org/apache/shardingsphere/infra/util/exception/internal/ShardingSphereInternalException.java
=>
kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/exception/PipelineInternalException.java
(66%)