Skip to content

Commit 15a0d73

Browse files
committed
[FLINK-38606][Connectors/MongoDB] Fixing formatting issues with spotless:apply
1 parent e81a8a8 commit 15a0d73

File tree

2 files changed

+4
-2
lines changed

2 files changed

+4
-2
lines changed

flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/MongoSourceReader.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -51,7 +51,8 @@ public MongoSourceReader(
5151
RecordEmitter<BsonDocument, OUT, MongoSourceSplitState> recordEmitter,
5252
MongoSourceReaderContext readerContext) {
5353
super(
54-
new SingleThreadFetcherManager<>(splitReaderSupplier, readerContext.getConfiguration()),
54+
new SingleThreadFetcherManager<>(
55+
splitReaderSupplier, readerContext.getConfiguration()),
5556
recordEmitter,
5657
readerContext.getConfiguration(),
5758
readerContext);

flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/sink/MongoSinkITCase.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -104,7 +104,8 @@ void testWriteToMongoWithDeliveryGuarantee(DeliveryGuarantee deliveryGuarantee)
104104
final MongoSink<Document> sink = createSink(collection, deliveryGuarantee);
105105
Configuration config = new Configuration();
106106
config.set(RestartStrategyOptions.RESTART_STRATEGY, "disable");
107-
final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(config);
107+
final StreamExecutionEnvironment env =
108+
StreamExecutionEnvironment.getExecutionEnvironment(config);
108109
env.enableCheckpointing(100L);
109110

110111
env.fromSequence(1, 5).map(new TestMapFunction()).sinkTo(sink);

0 commit comments

Comments
 (0)