diff --git a/src/test/java/io/pravega/connectors/flink/PravegaCatalogITCase.java b/src/test/java/io/pravega/connectors/flink/PravegaCatalogITCase.java
index 6a26bd33..3a9254e3 100644
--- a/src/test/java/io/pravega/connectors/flink/PravegaCatalogITCase.java
+++ b/src/test/java/io/pravega/connectors/flink/PravegaCatalogITCase.java
@@ -135,7 +135,7 @@ public void testCreateCatalogFromFactory() {
         assertThat(actualCatalog instanceof PravegaCatalog).isTrue();
         assertThat(((PravegaCatalog) actualCatalog).getName()).isEqualTo(CATALOG.getName());
         assertThat(((PravegaCatalog) actualCatalog).getDefaultDatabase()).isEqualTo(CATALOG.getDefaultDatabase());
-        org.assertj.core.api.Assertions.assertThat((Map) Whitebox.getInternalState(actualCatalog, "properties"))
+        assertThat((Map) Whitebox.getInternalState(actualCatalog, "properties"))
                 .isEqualTo(Whitebox.getInternalState(CATALOG, "properties"));
     }