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 2019c97a5ad Fix SHOW MIGRATION RULE always display default values when
ALTER MIGRATION RULE without STREAM_CHANNEL (#37737)
2019c97a5ad is described below
commit 2019c97a5adbb953bc032fb9650b25e6ec011325
Author: Hongsheng Zhong <[email protected]>
AuthorDate: Wed Jan 14 17:43:34 2026 +0800
Fix SHOW MIGRATION RULE always display default values when ALTER MIGRATION
RULE without STREAM_CHANNEL (#37737)
* Fix SHOW MIGRATION RULE always display default values when ALTER
MIGRATION RULE without STREAM_CHANNEL
* Update RELEASE-NOTES.md
---
RELEASE-NOTES.md | 1 +
.../config/yaml/config/YamlPipelineProcessConfiguration.java | 5 -----
.../core/metadata/PipelineProcessConfigurationPersistService.java | 2 +-
3 files changed, 2 insertions(+), 6 deletions(-)
diff --git a/RELEASE-NOTES.md b/RELEASE-NOTES.md
index 0ef3b428f47..486d38f99b4 100644
--- a/RELEASE-NOTES.md
+++ b/RELEASE-NOTES.md
@@ -124,6 +124,7 @@
1. Pipeline: Fix unsigned number column value type inconsistent in inventory
and incremental - [#37280](https://github.com/apache/shardingsphere/pull/37280)
1. Pipeline: Fix PostgreSQL migration create table SQL generation failure
caused by locale-formatted sequence values -
[#28360](https://github.com/apache/shardingsphere/issues/28360)
1. Pipeline: MySQLBinlogClient compatible with async exception -
[#37631](https://github.com/apache/shardingsphere/issues/37631)
+1. Pipeline: Fix SHOW MIGRATION RULE always display default values when ALTER
MIGRATION RULE without STREAM_CHANNEL -
[#37737](https://github.com/apache/shardingsphere/issues/37737)
1. DistSQL: Fix load single table with specific schema -
[#37535](https://github.com/apache/shardingsphere/pull/37535)
1. Transaction: Fix XA data source enlist failure caused connection leaks -
[37593](https://github.com/apache/shardingsphere/pull/37593)
diff --git
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/job/progress/config/yaml/config/YamlPipelineProcessConfiguration.java
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/job/progress/config/yaml/config/YamlPipelineProcessConfiguration.java
index 462094355e0..949407be9b8 100644
---
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/job/progress/config/yaml/config/YamlPipelineProcessConfiguration.java
+++
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/job/progress/config/yaml/config/YamlPipelineProcessConfiguration.java
@@ -34,9 +34,4 @@ public final class YamlPipelineProcessConfiguration
implements YamlConfiguration
private YamlPipelineWriteConfiguration write = new
YamlPipelineWriteConfiguration();
private YamlAlgorithmConfiguration streamChannel;
-
- @Override
- public boolean isEmpty() {
- return null == streamChannel;
- }
}
diff --git
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/metadata/PipelineProcessConfigurationPersistService.java
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/metadata/PipelineProcessConfigurationPersistService.java
index 3a70570ebd7..b881e169f1d 100644
---
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/metadata/PipelineProcessConfigurationPersistService.java
+++
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/metadata/PipelineProcessConfigurationPersistService.java
@@ -39,7 +39,7 @@ public final class PipelineProcessConfigurationPersistService
implements Pipelin
return null;
}
YamlPipelineProcessConfiguration yamlConfig =
YamlEngine.unmarshal(yamlText, YamlPipelineProcessConfiguration.class, true);
- return yamlConfig.isEmpty() ? null : swapper.swapToObject(yamlConfig);
+ return swapper.swapToObject(yamlConfig);
}
@Override
