You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by ji...@apache.org on 2022/11/01 03:29:16 UTC
[shardingsphere] branch master updated: Fix issue 21867 (#21876)
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 <57...@users.noreply.github.com>
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);
}