Skip to content

Commit 8b97772

Browse files
Spotless check done
1 parent 49ceaa7 commit 8b97772

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/AsyncSinkWriter.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -109,8 +109,8 @@ public abstract class AsyncSinkWriter<InputT, RequestEntryT extends Serializable
109109
*
110110
* <p>The buffer stores {@link RequestEntryWrapper} objects rather than raw {@link
111111
* RequestEntryT} instances, as buffering wrapped entries allows for better tracking of size and
112-
* metadata. This also makes it easier to handle retries by prioritising failed entries back into
113-
* the buffer.
112+
* metadata. This also makes it easier to handle retries by prioritising failed entries back
113+
* into the buffer.
114114
*/
115115
private final BufferWrapper<RequestEntryT> bufferedRequestEntries;
116116

0 commit comments

Comments
 (0)