Skip to content

Commit

Permalink
[hotfix] [s3] Minor fixes/code simplifications in S3 recoverable writer
Browse files Browse the repository at this point in the history
  • Loading branch information
StephanEwen committed Nov 16, 2018
1 parent 9f94556 commit 89548ba
Show file tree
Hide file tree
Showing 2 changed files with 1 addition and 34 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,6 @@
import org.apache.flink.util.FlinkRuntimeException;

import java.util.concurrent.Executor;
import java.util.concurrent.RejectedExecutionException;
import java.util.concurrent.Semaphore;
import java.util.concurrent.atomic.AtomicBoolean;

Expand Down Expand Up @@ -66,11 +65,9 @@ public void execute(Runnable command) {
final SemaphoreReleasingRunnable runnable = new SemaphoreReleasingRunnable(command, permits);
try {
delegate.execute(runnable);
} catch (RejectedExecutionException e) {
} catch (Throwable e) {
runnable.release();
ExceptionUtils.rethrow(e, e.getMessage());
} catch (Throwable t) {
ExceptionUtils.rethrow(t, t.getMessage());
}
}

Expand Down

This file was deleted.

0 comments on commit 89548ba

Please sign in to comment.