fix: compile errors

eclipse-edc · Oct 9, 2023 · d030ae7 · d030ae7
1 parent f5c269a
commit d030ae7
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/...ata-plane-aws-s3/src/main/java/org/eclipse/edc/connector/dataplane/aws/s3/S3DataSink.java b/...ata-plane-aws-s3/src/main/java/org/eclipse/edc/connector/dataplane/aws/s3/S3DataSink.java
@@ -43,7 +43,7 @@ class S3DataSink extends ParallelSink {
     private S3DataSink() {}
 
     @Override
-    protected StreamResult<Void> transferParts(List<DataSource.Part> parts) {
+    protected StreamResult<Object> transferParts(List<DataSource.Part> parts) {
         for (var part : parts) {
             try (var input = part.openStream()) {
 
@@ -90,7 +90,7 @@ protected StreamResult<Void> transferParts(List<DataSource.Part> parts) {
     }
 
     @Override
-    protected StreamResult<Void> complete() {
+    protected StreamResult<Object> complete() {
         var completeKeyName = keyName + ".complete";
         var request = PutObjectRequest.builder().bucket(bucketName).key(completeKeyName).build();
         try {
@@ -103,7 +103,7 @@ protected StreamResult<Void> complete() {
     }
 
     @NotNull
-    private StreamResult<Void> uploadFailure(Exception e, String keyName) {
+    private StreamResult<Object> uploadFailure(Exception e, String keyName) {
         var message = format("Error writing the %s object on the %s bucket: %s", keyName, bucketName, e.getMessage());
         monitor.severe(message, e);
         return StreamResult.error(message);

diff --git a/...a-plane-aws-s3/src/main/java/org/eclipse/edc/connector/dataplane/aws/s3/S3DataSource.java b/...a-plane-aws-s3/src/main/java/org/eclipse/edc/connector/dataplane/aws/s3/S3DataSource.java
@@ -40,8 +40,8 @@ public StreamResult<Stream<Part>> openPartStream() {
     }
 
     @Override
-    public void close() {
-
+    public void close() throws Exception {
+        client.close();
     }
 
     private static class S3Part implements Part {