Skip to content

Commit 0d3d824

Browse files
committed
[FLINK-38606][Connectors/MongoDB] Fixing formatting issues with spotless:apply & change to only support jdk 17 & 18 only
1 parent e81a8a8 commit 0d3d824

File tree

3 files changed

+6
-4
lines changed

3 files changed

+6
-4
lines changed

.github/workflows/push_pr.yml

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -29,8 +29,8 @@ jobs:
2929
strategy:
3030
matrix:
3131
mongodb: [ mongodb4, mongodb5, mongodb6, mongodb7 ]
32-
flink: [ 1.19-SNAPSHOT, 1.20-SNAPSHOT ]
33-
jdk: [ '8, 11, 17, 21' ]
32+
flink: [ 2.1-SNAPSHOT ]
33+
jdk: [ '17, 21' ]
3434

3535
uses: apache/flink-connector-shared-utils/.github/workflows/ci.yml@ci_utils
3636
with:

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)