yujunjun/datahub
2
0
Fork 0
mirror of https://github.com/datahub-project/datahub.git synced 2025-12-27 09:58:14 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(ci): spark-lineage - select mock server port dynamically for unit test (#4018)

Browse Source
This commit is contained in:
MugdhaHardikar-GSLab 2022-01-31 22:56:26 +05:30 committed by GitHub
parent faac911df8
commit 4c33124e8f
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
metadata-integration/java/spark-lineage/src/test/java/datahub/spark/TestSparkJobsLineage.java
View File

@ -39,6 +39,7 @@ import org.mockserver.integration.ClientAndServer;
import org.mockserver.matchers.Times;
import org.mockserver.model.HttpResponse;
import org.mockserver.model.JsonBody;
import org.mockserver.socket.PortFactory;
import org.mockserver.verify.VerificationTimes;
import org.testcontainers.containers.PostgreSQLContainer;
@ -64,7 +65,8 @@ public class TestSparkJobsLineage {
private static final int N = 3; // num of GMS requests per spark job
private static final int GMS_PORT = MOCK_GMS ? 8089 : 8080;
private static final int MOCK_PORT = PortFactory.findFreePort();
private static final int GMS_PORT = MOCK_GMS ? MOCK_PORT : 8080;
private static final String EXPECTED_JSON_ROOT = "src/test/resources/expected/";
@ClassRule
@ -101,7 +103,7 @@ public class TestSparkJobsLineage {
}
public static void init() {
mockServer = startClientAndServer();
mockServer = startClientAndServer(GMS_PORT);
resetBaseExpectations();
}
@ -434,4 +436,4 @@ public class TestSparkJobsLineage {
closed = true;
}
}
}
}