Skip to content

Commit afdbe64

Browse files
committed
spot check apply
1 parent 3736f3b commit afdbe64

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/sink/FlinkSink.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -58,14 +58,16 @@ class FlinkSink<InputT> implements Sink<InputT>, SupportsPreWriteTopology<InputT
5858
@Deprecated
5959
@Override
6060
public SinkWriter<InputT> createWriter(InitContext context) throws IOException {
61-
FlinkSinkWriter<InputT> flinkSinkWriter = builder.createWriter(context.getMailboxExecutor());
61+
FlinkSinkWriter<InputT> flinkSinkWriter =
62+
builder.createWriter(context.getMailboxExecutor());
6263
flinkSinkWriter.initialize(InternalSinkWriterMetricGroup.wrap(context.metricGroup()));
6364
return flinkSinkWriter;
6465
}
6566

6667
@Override
6768
public SinkWriter<InputT> createWriter(WriterInitContext context) throws IOException {
68-
FlinkSinkWriter<InputT> flinkSinkWriter = builder.createWriter(context.getMailboxExecutor());
69+
FlinkSinkWriter<InputT> flinkSinkWriter =
70+
builder.createWriter(context.getMailboxExecutor());
6971
flinkSinkWriter.initialize(InternalSinkWriterMetricGroup.wrap(context.metricGroup()));
7072
return flinkSinkWriter;
7173
}

0 commit comments

Comments
 (0)