Fix logging

takezoe · Sep 24, 2021 · a08a3f1 · a08a3f1
1 parent 0a5f074
commit a08a3f1
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/main/java/io/github/takezoe/trino/openlineage/OpenLineageClient.java b/src/main/java/io/github/takezoe/trino/openlineage/OpenLineageClient.java
@@ -47,6 +47,7 @@ public OpenLineageClient(String url, Optional<String> apiKey)
     public void emit(OpenLineage.RunEvent event)
     {
         try {
+            // TODO: Do asynchronously with retry if failed
             String json = objectMapper.writeValueAsString(event);
             logger.info(json);
 
@@ -61,7 +62,7 @@ public void emit(OpenLineage.RunEvent event)
             }
 
             StatusResponseHandler.StatusResponse status = jettyClient.execute(requestBuilder.build(), StatusResponseHandler.createStatusResponseHandler());
-            System.out.println(status.getStatusCode());
+            logger.info("Response status: " + status.getStatusCode());
         }
         catch (Exception e) {
             logger.error(e);