diff --git a/src/test/java/io/pravega/connectors/flink/sink/PravegaSinkWriterITCase.java b/src/test/java/io/pravega/connectors/flink/sink/PravegaSinkWriterITCase.java index 60e640d1..5bccd793 100644 --- a/src/test/java/io/pravega/connectors/flink/sink/PravegaSinkWriterITCase.java +++ b/src/test/java/io/pravega/connectors/flink/sink/PravegaSinkWriterITCase.java @@ -148,7 +148,7 @@ private static class SinkInitContext implements Sink.InitContext { SinkInitContext( SinkWriterMetricGroup metricGroup) { this.metricGroup = metricGroup; - } + } @Override public JobID getJobId() {