diff --git a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/job/option/PipelineJobOption.java b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/job/option/PipelineJobOption.java index 55f0c235f1d2a..ce65bf34c5792 100644 --- a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/job/option/PipelineJobOption.java +++ b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/job/option/PipelineJobOption.java @@ -24,7 +24,6 @@ import org.apache.shardingsphere.data.pipeline.core.job.yaml.YamlPipelineJobItemProgressConfiguration; import org.apache.shardingsphere.data.pipeline.core.job.yaml.YamlPipelineJobItemProgressSwapper; import org.apache.shardingsphere.infra.spi.annotation.SingletonSPI; -import org.apache.shardingsphere.infra.spi.type.typed.TypedSPI; import org.apache.shardingsphere.infra.util.yaml.YamlConfiguration; import java.util.Optional; @@ -33,7 +32,7 @@ * Pipeline job option. */ @SingletonSPI -public interface PipelineJobOption extends TypedSPI { +public interface PipelineJobOption { /** * Get YAML pipeline job configuration swapper. @@ -95,6 +94,10 @@ default boolean isForceNoShardingWhenConvertToJobConfigurationPOJO() { */ Class getJobClass(); - @Override + /** + * Get job type. + * + * @return job type + */ String getType(); }