Fixing build

datahub-project · Feb 16, 2024 · 8d911d1 · 8d911d1
1 parent f0cf22e
commit 8d911d1
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 14 deletions.
diff --git a/...ineage-servlet/src/main/java/io/datahubproject/openlineage/controller/LineageApiImpl.java b/...ineage-servlet/src/main/java/io/datahubproject/openlineage/controller/LineageApiImpl.java
@@ -6,7 +6,6 @@
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.linkedin.common.AuditStamp;
 import com.linkedin.common.urn.UrnUtils;
-import com.linkedin.entity.client.EntityClient;
 import com.linkedin.metadata.entity.EntityServiceImpl;
 import com.linkedin.mxe.MetadataChangeProposal;
 import io.datahubproject.openlineage.generated.controller.LineageApi;
@@ -17,7 +16,6 @@
 import java.util.stream.Collectors;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.http.HttpStatus;
 import org.springframework.http.ResponseEntity;
@@ -32,9 +30,9 @@ public class LineageApiImpl implements LineageApi {
 
   @Autowired private RunEventMapper.MappingConfig _mappingConfig;
 
- // @Autowired
-  //@Qualifier("javaEntityClient")
-  //private EntityClient _entityClient;
+  // @Autowired
+  // @Qualifier("javaEntityClient")
+  // private EntityClient _entityClient;
 
   @Autowired private EntityServiceImpl _entityService;
 

diff --git a/...enlineage-servlet/src/main/java/io/datahubproject/openlineage/mapping/RunEventMapper.java b/...enlineage-servlet/src/main/java/io/datahubproject/openlineage/mapping/RunEventMapper.java
@@ -24,15 +24,7 @@ public Stream<MetadataChangeProposal> map(
     try {
       return convertRunEventToJob(runEvent, mappingConfig.getDatahubConfig())
           .toMcps(mappingConfig.datahubConfig)
-          .stream()
-          .map(
-              mcp -> {
-                try {
-                  return eventFormatter.convert(mcp);
-                } catch (IOException e) {
-                  throw new RuntimeException(e);
-                }
-              });
+          .stream();
     } catch (IOException | URISyntaxException e) {
       throw new RuntimeException(e);
     }