[Feature][Connector-V2][FTS] Fix code style

apache · Mar 14, 2023 · c484edf · c484edf
1 parent 3e3620b
commit c484edf
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/...ava/org/apache/seatunnel/connectors/seatunnel/fts/source/FlinkTableStoreSourceReader.java b/...ava/org/apache/seatunnel/connectors/seatunnel/fts/source/FlinkTableStoreSourceReader.java
@@ -72,10 +72,12 @@ public void pollNext(Collector<SeaTunnelRow> output) throws Exception {
                 // read logic
                 try (final RecordReader<RowData> reader =
                         table.newRead().createReader(split.getSplit())) {
-                    final RecordReaderIterator<RowData> rowIterator = new RecordReaderIterator<>(reader);
+                    final RecordReaderIterator<RowData> rowIterator =
+                            new RecordReaderIterator<>(reader);
                     while (rowIterator.hasNext()) {
                         final RowData row = rowIterator.next();
-                        final SeaTunnelRow seaTunnelRow = RowConverter.convert(row, seaTunnelRowType);
+                        final SeaTunnelRow seaTunnelRow =
+                                RowConverter.convert(row, seaTunnelRowType);
                         output.collect(seaTunnelRow);
                     }
                 }