This is an automated email from the ASF dual-hosted git repository.
terrymanu 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 a326cb1db10 Remove unrelated pipeline API factory test (#39774)
a326cb1db10 is described below
commit a326cb1db10124f6df09b8a20fa10a534bb8f3ed
Author: Liang Zhang <[email protected]>
AuthorDate: Wed Sep 9 01:12:02 2026 +0800
Remove unrelated pipeline API factory test (#39774)
---
.../pipeline/core/job/api/PipelineAPIFactoryTest.java | 15 ---------------
1 file changed, 15 deletions(-)
diff --git
a/kernel/data-pipeline/core/src/test/java/org/apache/shardingsphere/data/pipeline/core/job/api/PipelineAPIFactoryTest.java
b/kernel/data-pipeline/core/src/test/java/org/apache/shardingsphere/data/pipeline/core/job/api/PipelineAPIFactoryTest.java
index bdcda1c865c..7036e91facc 100644
---
a/kernel/data-pipeline/core/src/test/java/org/apache/shardingsphere/data/pipeline/core/job/api/PipelineAPIFactoryTest.java
+++
b/kernel/data-pipeline/core/src/test/java/org/apache/shardingsphere/data/pipeline/core/job/api/PipelineAPIFactoryTest.java
@@ -18,7 +18,6 @@
package org.apache.shardingsphere.data.pipeline.core.job.api;
import lombok.SneakyThrows;
-import org.apache.commons.lang3.concurrent.ConcurrentException;
import org.apache.shardingsphere.data.pipeline.core.context.PipelineContextKey;
import
org.apache.shardingsphere.data.pipeline.core.context.PipelineContextManager;
import
org.apache.shardingsphere.data.pipeline.core.metadata.node.PipelineMetaDataNode;
@@ -128,20 +127,6 @@ class PipelineAPIFactoryTest {
}
}
- @Test
- void assertGetPipelineGovernanceFacadePropagatesInitializationFailure() {
- PipelineContextKey contextKey = new PipelineContextKey("error_db",
InstanceType.JDBC);
- ConcurrentException expected = new ConcurrentException(new
Exception("expected"));
- try (MockedStatic<PipelineContextManager> contextManager =
mockStatic(PipelineContextManager.class)) {
- contextManager.when(() ->
PipelineContextManager.getContext(contextKey)).thenAnswer(invocation -> {
- throw expected;
- });
- assertThat(assertThrows(ConcurrentException.class, () ->
PipelineAPIFactory.getPipelineGovernanceFacade(contextKey)),
sameInstance(expected));
- } finally {
- PipelineAPIFactory.close(contextKey);
- }
- }
-
private ClusterPersistRepositoryConfiguration mockContext(final
PipelineContextKey contextKey, final MockedStatic<PipelineContextManager>
pipelineContextManager) {
ClusterPersistRepositoryConfiguration result = new
ClusterPersistRepositoryConfiguration("FIXTURE", "namespace", "serverLists",
new Properties());
ContextManager contextManager = mock(ContextManager.class,
RETURNS_DEEP_STUBS);