[shardingsphere] branch master updated: Fixed scaling incremental failure due to the null column value (#19071)

[zhonghongsheng]

This is an automated email from the ASF dual-hosted git repository.

zhonghongsheng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git


The following commit(s) were added to refs/heads/master by this push:
     new d6bfc7c5f51 Fixed scaling incremental failure due to the null column 
value (#19071)
d6bfc7c5f51 is described below

commit d6bfc7c5f516235b0406b1abb2d9c7ff74b9f3cf
Author: azexcy <101622833+aze...@users.noreply.github.com>
AuthorDate: Thu Jul 14 09:45:48 2022 +0800

    Fixed scaling incremental failure due to the null column value (#19071)
    
    * Fix #19070
    
    * Change code style
---
 .../data/pipeline/opengauss/ingest/wal/decode/MppdbDecodingPlugin.java | 3 +++
 1 file changed, 3 insertions(+)

diff --git 
a/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-dialect/shardingsphere-data-pipeline-opengauss/src/main/java/org/apache/shardingsphere/data/pipeline/opengauss/ingest/wal/decode/MppdbDecodingPlugin.java
 
b/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-dialect/shardingsphere-data-pipeline-opengauss/src/main/java/org/apache/shardingsphere/data/pipeline/opengauss/ingest/wal/decode/MppdbDecodingPlugin.java
index b7a8159447d..ac081fe570c 100644
--- 
a/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-dialect/shardingsphere-data-pipeline-opengauss/src/main/java/org/apache/shardingsphere/data/pipeline/opengauss/ingest/wal/decode/MppdbDecodingPlugin.java
+++ 
b/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-dialect/shardingsphere-data-pipeline-opengauss/src/main/java/org/apache/shardingsphere/data/pipeline/opengauss/ingest/wal/decode/MppdbDecodingPlugin.java
@@ -138,6 +138,9 @@ public final class MppdbDecodingPlugin implements 
DecodingPlugin {
     }
     
     private Object readColumnData(final String data, final String columnType) {
+        if ("null".equals(data)) {
+            return null;
+        }
         if (columnType.startsWith("numeric")) {
             return new BigDecimal(data);
         }