This is an automated email from the ASF dual-hosted git repository.
vernedeng pushed a commit to branch branch-1.10
in repository https://gitbox.apache.org/repos/asf/inlong.git
commit 5248e4ca06c069924c97f9ad19dcee82d8783e42
Author: vernedeng <verned...@apache.org>
AuthorDate: Tue Dec 12 16:42:30 2023 +0800
[INLONG-9461][Manager] Fix failure of GroupTaskListenerFactoryTest (#9462)
* [INLONG-9461][Manager] Fix failure of GroupTaskListenerFactoryTest
---------
Co-authored-by: fuweng11 <76141879+fuwen...@users.noreply.github.com>
(cherry picked from commit b90e96b4807778a6f462810201f139186bffa8f7)
---
.github/workflows/ci_ut.yml | 2 +-
.../workflow/GroupTaskListenerFactoryTest.java | 65 ----------------------
.../sort-end-to-end-tests-v1.13/pom.xml | 3 -
.../sort-end-to-end-tests-v1.15/pom.xml | 3 -
4 files changed, 1 insertion(+), 72 deletions(-)
diff --git a/.github/workflows/ci_ut.yml b/.github/workflows/ci_ut.yml
index 636dd2d9b3..180a8e2876 100644
--- a/.github/workflows/ci_ut.yml
+++ b/.github/workflows/ci_ut.yml
@@ -101,7 +101,7 @@ jobs:
CI: false
- name: Unit test with Maven
- run: mvn --batch-mode --update-snapshots -e -V verify
+ run: mvn --batch-mode --update-snapshots -e -V test
env:
CI: false
diff --git
a/inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/workflow/GroupTaskListenerFactoryTest.java
b/inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/workflow/GroupTaskListenerFactoryTest.java
deleted file mode 100644
index 4165205935..0000000000
---
a/inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/workflow/GroupTaskListenerFactoryTest.java
+++ /dev/null
@@ -1,65 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.inlong.manager.service.workflow;
-
-import org.apache.inlong.common.constant.MQType;
-import org.apache.inlong.manager.pojo.group.pulsar.InlongPulsarInfo;
-import org.apache.inlong.manager.pojo.group.tubemq.InlongTubeMQInfo;
-import
org.apache.inlong.manager.pojo.workflow.form.process.GroupResourceProcessForm;
-import org.apache.inlong.manager.service.ServiceBaseTest;
-import org.apache.inlong.manager.service.listener.GroupTaskListenerFactory;
-import org.apache.inlong.manager.workflow.WorkflowContext;
-import org.apache.inlong.manager.workflow.event.task.QueueOperateListener;
-
-import org.junit.jupiter.api.Assertions;
-import org.junit.jupiter.api.Test;
-import org.springframework.beans.factory.annotation.Autowired;
-
-import java.util.List;
-
-/**
- * Test class for get queue operate listener.
- */
-public class GroupTaskListenerFactoryTest extends ServiceBaseTest {
-
- @Autowired
- private GroupTaskListenerFactory groupTaskListenerFactory;
-
- @Test
- public void testGetQueueOperateListener() {
- GroupResourceProcessForm processForm = new GroupResourceProcessForm();
- InlongPulsarInfo pulsarInfo = new InlongPulsarInfo();
- // check pulsar listener
- pulsarInfo.setMqType(MQType.PULSAR);
- processForm.setGroupInfo(pulsarInfo);
- WorkflowContext context = new WorkflowContext();
- context.setProcessForm(processForm);
- List<QueueOperateListener> queueOperateListeners =
groupTaskListenerFactory.getQueueResourceListener(context);
- if (queueOperateListeners.size() == 0) {
- return;
- }
- Assertions.assertEquals(1, queueOperateListeners.size());
-
- // check tubemq listener
- InlongTubeMQInfo tubeInfo = new InlongTubeMQInfo();
- tubeInfo.setMqType(MQType.TUBEMQ);
- queueOperateListeners =
groupTaskListenerFactory.getQueueResourceListener(context);
- Assertions.assertEquals(2, queueOperateListeners.size());
- }
-
-}
diff --git
a/inlong-sort/sort-end-to-end-tests/sort-end-to-end-tests-v1.13/pom.xml
b/inlong-sort/sort-end-to-end-tests/sort-end-to-end-tests-v1.13/pom.xml
index e79d6c3b71..c67331ef09 100644
--- a/inlong-sort/sort-end-to-end-tests/sort-end-to-end-tests-v1.13/pom.xml
+++ b/inlong-sort/sort-end-to-end-tests/sort-end-to-end-tests-v1.13/pom.xml
@@ -193,9 +193,6 @@
<executions>
<execution>
<id>end-to-end-tests-v1.13</id>
- <goals>
- <goal>integration-test</goal>
- </goals>
<phase>integration-test</phase>
<configuration>
<includes>
diff --git
a/inlong-sort/sort-end-to-end-tests/sort-end-to-end-tests-v1.15/pom.xml
b/inlong-sort/sort-end-to-end-tests/sort-end-to-end-tests-v1.15/pom.xml
index b800ead11f..1644aa2b76 100644
--- a/inlong-sort/sort-end-to-end-tests/sort-end-to-end-tests-v1.15/pom.xml
+++ b/inlong-sort/sort-end-to-end-tests/sort-end-to-end-tests-v1.15/pom.xml
@@ -242,9 +242,6 @@
<executions>
<execution>
<id>end-to-end-tests-v1.15</id>
- <goals>
- <goal>integration-test</goal>
- </goals>
<phase>integration-test</phase>
<configuration>
<includes>
