[shardingsphere] branch master updated: Fix occasional ci error (#22905)

[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 8d664d26ef9 Fix occasional ci error (#22905)
8d664d26ef9 is described below

commit 8d664d26ef91c81484a6689ff4e65f1fff3a9580
Author: Xinze Guo <101622833+aze...@users.noreply.github.com>
AuthorDate: Fri Dec 16 14:24:32 2022 +0800

    Fix occasional ci error (#22905)
---
 .../test/it/data/pipeline/core/task/InventoryTaskTest.java       | 9 ++++-----
 1 file changed, 4 insertions(+), 5 deletions(-)

diff --git 
a/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/task/InventoryTaskTest.java
 
b/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/task/InventoryTaskTest.java
index 5276b24f1f4..d801576cd9b 100644
--- 
a/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/task/InventoryTaskTest.java
+++ 
b/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/task/InventoryTaskTest.java
@@ -24,14 +24,13 @@ import 
org.apache.shardingsphere.data.pipeline.api.datasource.PipelineDataSource
 import 
org.apache.shardingsphere.data.pipeline.api.ingest.position.IntegerPrimaryKeyPosition;
 import 
org.apache.shardingsphere.data.pipeline.api.metadata.loader.PipelineTableMetaDataLoader;
 import 
org.apache.shardingsphere.data.pipeline.core.datasource.DefaultPipelineDataSourceManager;
-import 
org.apache.shardingsphere.data.pipeline.core.importer.connector.DataSourceImporterConnector;
-import 
org.apache.shardingsphere.test.it.data.pipeline.core.fixture.FixtureImporterConnector;
-import 
org.apache.shardingsphere.test.it.data.pipeline.core.fixture.FixtureInventoryIncrementalJobItemContext;
 import 
org.apache.shardingsphere.data.pipeline.core.metadata.loader.StandardPipelineTableMetaDataLoader;
 import org.apache.shardingsphere.data.pipeline.core.task.InventoryTask;
+import 
org.apache.shardingsphere.data.pipeline.scenario.migration.config.MigrationTaskConfiguration;
+import 
org.apache.shardingsphere.test.it.data.pipeline.core.fixture.FixtureImporterConnector;
+import 
org.apache.shardingsphere.test.it.data.pipeline.core.fixture.FixtureInventoryIncrementalJobItemContext;
 import 
org.apache.shardingsphere.test.it.data.pipeline.core.util.JobConfigurationBuilder;
 import 
org.apache.shardingsphere.test.it.data.pipeline.core.util.PipelineContextUtil;
-import 
org.apache.shardingsphere.data.pipeline.scenario.migration.config.MigrationTaskConfiguration;
 import org.junit.AfterClass;
 import org.junit.Before;
 import org.junit.BeforeClass;
@@ -77,7 +76,7 @@ public final class InventoryTaskTest {
         PipelineTableMetaDataLoader metaDataLoader = new 
StandardPipelineTableMetaDataLoader(dataSource);
         try (
                 InventoryTask inventoryTask = new 
InventoryTask(inventoryDumperConfig, taskConfig.getImporterConfig(),
-                        PipelineContextUtil.getPipelineChannelCreator(), new 
DataSourceImporterConnector(DATA_SOURCE_MANAGER), dataSource,
+                        PipelineContextUtil.getPipelineChannelCreator(), new 
FixtureImporterConnector(), dataSource,
                         metaDataLoader, 
PipelineContextUtil.getExecuteEngine(), PipelineContextUtil.getExecuteEngine(), 
new FixtureInventoryIncrementalJobItemContext())) {
             CompletableFuture.allOf(inventoryTask.start().toArray(new 
CompletableFuture[0])).get(10, TimeUnit.SECONDS);
         }