This is an automated email from the ASF dual-hosted git repository.
jianglongtao 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 1c66cbbac3d Fix issue 21867 (#21876)
1c66cbbac3d is described below
commit 1c66cbbac3deb29a56259ce2e0c5ccbb5369d677
Author: Zichao <[email protected]>
AuthorDate: Tue Nov 1 16:29:10 2022 +1300
Fix issue 21867 (#21876)
---
.../data/pipeline/scenario/migration/MigrationJobAPIImpl.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/MigrationJobAPIImpl.java
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/MigrationJobAPIImpl.java
index 245ac97eb2e..0e5b65d7b84 100644
---
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/MigrationJobAPIImpl.java
+++
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/MigrationJobAPIImpl.java
@@ -352,7 +352,7 @@ public final class MigrationJobAPIImpl extends
AbstractInventoryIncrementalJobAP
public void dropMigrationSourceResources(final Collection<String>
resourceNames) {
Map<String, DataSourceProperties> metaDataDataSource =
dataSourcePersistService.load(getJobType());
List<String> noExistResources = resourceNames.stream().filter(each ->
!metaDataDataSource.containsKey(each)).collect(Collectors.toList());
- ShardingSpherePreconditions.checkState(noExistResources.isEmpty(), ()
-> new UnregisterMigrationSourceStorageUnitException(resourceNames));
+ ShardingSpherePreconditions.checkState(noExistResources.isEmpty(), ()
-> new UnregisterMigrationSourceStorageUnitException(noExistResources));
for (String each : resourceNames) {
metaDataDataSource.remove(each);
}
