add profile info

mchades · Jun 24, 2024 · 9755834 · 9755834
1 parent ca9f220
commit 9755834
Show file tree

Hide file tree

Showing 10 changed files with 51 additions and 1 deletion.
diff --git a/.github/workflows/backend-integration-test.yml b/.github/workflows/backend-integration-test.yml
@@ -99,7 +99,7 @@ jobs:
           ./gradlew test -PskipTests -PtestMode=${{ matrix.test-mode }} -PjdkVersion=${{ matrix.java-version }} -P${{ matrix.backend }} -PskipWebITs 
           -x :web:test -x :clients:client-python:test -x :flink-connector:test -x :spark-connector:test -x :spark-connector:spark-common:test 
           -x :spark-connector:spark-3.3:test -x :spark-connector:spark-3.4:test -x :spark-connector:spark-3.5:test 
-          -x :spark-connector:spark-runtime-3.3:test -x :spark-connector:spark-runtime-3.4:test -x :spark-connector:spark-runtime-3.5:test
+          -x :spark-connector:spark-runtime-3.3:test -x :spark-connector:spark-runtime-3.4:test -x :spark-connector:spark-runtime-3.5:test --profile
 
       - name: Upload integrate tests reports
         uses: actions/upload-artifact@v3

diff --git a/...mon/src/test/java/com/datastrato/gravitino/integration/test/container/DorisContainer.java b/...mon/src/test/java/com/datastrato/gravitino/integration/test/container/DorisContainer.java
@@ -60,9 +60,14 @@ protected void setupContainer() {
 
   @Override
   public void start() {
+    LOG.info("starting Doris container...");
+    long currentTime = System.currentTimeMillis();
+
     super.start();
     Preconditions.check("Doris container startup failed!", checkContainerStatus(5));
     Preconditions.check("Doris container password change failed!", changePassword());
+
+    LOG.info("Ranger Doris start successfully in {}ms", System.currentTimeMillis() - currentTime);
   }
 
   @Override

diff --git a/...mmon/src/test/java/com/datastrato/gravitino/integration/test/container/HiveContainer.java b/...mmon/src/test/java/com/datastrato/gravitino/integration/test/container/HiveContainer.java
@@ -62,8 +62,12 @@ protected void setupContainer() {
 
   @Override
   public void start() {
+    LOG.info("starting Hive container...");
+    long currentTime = System.currentTimeMillis();
+
     super.start();
     Preconditions.check("Hive container startup failed!", checkContainerStatus(15));
+    LOG.info("Hive container start successfully in {}ms", System.currentTimeMillis() - currentTime);
   }
 
   @Override

diff --git a/...mon/src/test/java/com/datastrato/gravitino/integration/test/container/KafkaContainer.java b/...mon/src/test/java/com/datastrato/gravitino/integration/test/container/KafkaContainer.java
@@ -47,8 +47,14 @@ public static Builder builder() {
 
   @Override
   public void start() {
+    LOG.info("starting Kafka container...");
+    long currentTime = System.currentTimeMillis();
+
     super.start();
     Preconditions.checkArgument(checkContainerStatus(5), "Kafka container startup failed!");
+
+    LOG.info(
+        "Kafka container start successfully in {}ms", System.currentTimeMillis() - currentTime);
   }
 
   @Override

diff --git a/...mon/src/test/java/com/datastrato/gravitino/integration/test/container/MySQLContainer.java b/...mon/src/test/java/com/datastrato/gravitino/integration/test/container/MySQLContainer.java
@@ -56,8 +56,13 @@ protected void setupContainer() {
 
   @Override
   public void start() {
+    LOG.info("starting MySQL container...");
+    long currentTime = System.currentTimeMillis();
+
     super.start();
     Preconditions.check("MySQL container startup failed!", checkContainerStatus(5));
+    LOG.info(
+        "MySQL container start successfully in {}ms", System.currentTimeMillis() - currentTime);
   }
 
   @Override

diff --git a/...rc/test/java/com/datastrato/gravitino/integration/test/container/PostgreSQLContainer.java b/...rc/test/java/com/datastrato/gravitino/integration/test/container/PostgreSQLContainer.java
@@ -54,8 +54,14 @@ protected void setupContainer() {
 
   @Override
   public void start() {
+    LOG.info("starting Ranger container...");
+    long currentTime = System.currentTimeMillis();
+
     super.start();
     Preconditions.check("PostgreSQL container startup failed!", checkContainerStatus(5));
+    LOG.info(
+        "PostgreSQL container start successfully in {}ms",
+        System.currentTimeMillis() - currentTime);
   }
 
   @Override

diff --git a/...on/src/test/java/com/datastrato/gravitino/integration/test/container/RangerContainer.java b/...on/src/test/java/com/datastrato/gravitino/integration/test/container/RangerContainer.java
@@ -58,12 +58,18 @@ protected void setupContainer() {
 
   @Override
   public void start() {
+    LOG.info("starting Ranger container...");
+    long currentTime = System.currentTimeMillis();
+
     super.start();
 
     rangerUrl = String.format("http://localhost:%s", this.getMappedPort(6080));
     rangerClient = new RangerClient(rangerUrl, authType, username, password, null);
 
     Preconditions.check("Ranger container startup failed!", checkContainerStatus(10));
+
+    LOG.info(
+        "Ranger container start successfully in {}ms", System.currentTimeMillis() - currentTime);
   }
 
   @Override

diff --git a/...mon/src/test/java/com/datastrato/gravitino/integration/test/container/TrinoContainer.java b/...mon/src/test/java/com/datastrato/gravitino/integration/test/container/TrinoContainer.java
@@ -59,10 +59,16 @@ protected void setupContainer() {
 
   @Override
   public void start() {
+    LOG.info("starting Trino container...");
+    long currentTime = System.currentTimeMillis();
+
     super.start();
 
     Preconditions.check("Initialization Trino JDBC connect failed!", initTrinoJdbcConnection());
     Preconditions.check("Trino container startup failed!", checkContainerStatus(5));
+
+    LOG.info(
+        "Trino container start successfully in {}ms", System.currentTimeMillis() - currentTime);
   }
 
   @Override

diff --git a/.../src/test/java/com/datastrato/gravitino/integration/test/container/TrinoITContainers.java b/.../src/test/java/com/datastrato/gravitino/integration/test/container/TrinoITContainers.java
@@ -35,6 +35,9 @@ public class TrinoITContainers implements AutoCloseable {
   }
 
   public void launch(int gravitinoServerPort) throws Exception {
+    LOG.info("starting Trino IT containers...");
+    long currentTime = System.currentTimeMillis();
+
     shutdown();
 
     Map<String, String> env = new HashMap<>();
@@ -56,6 +59,9 @@ public void launch(int gravitinoServerPort) throws Exception {
     }
 
     resolveServerAddress();
+
+    LOG.info(
+        "Trino IT containers start successfully in {}ms", System.currentTimeMillis() - currentTime);
   }
 
   private void resolveServerAddress() throws Exception {

diff --git a/...-test-common/src/test/java/com/datastrato/gravitino/integration/test/util/AbstractIT.java b/...-test-common/src/test/java/com/datastrato/gravitino/integration/test/util/AbstractIT.java
@@ -202,6 +202,7 @@ public static void startIntegrationTest() throws Exception {
     }
 
     serverConfig = new ServerConfig();
+    long currentTime = System.currentTimeMillis();
     if (testMode != null && testMode.equals(ITUtils.EMBEDDED_TEST_MODE)) {
       MiniGravitinoContext context =
           new MiniGravitinoContext(customConfigs, ignoreIcebergRestService);
@@ -235,6 +236,11 @@ public static void startIntegrationTest() throws Exception {
           .until(() -> isHttpServerUp(checkServerUrl));
     }
 
+    LOG.info(
+        "Gravitino {} server start successfully in {}ms",
+        testMode,
+        System.currentTimeMillis() - currentTime);
+
     JettyServerConfig jettyServerConfig =
         JettyServerConfig.fromConfig(serverConfig, WEBSERVER_CONF_PREFIX);