Skip to content

Commit e8fe75e

Browse files
committed
[FLINK-14068][streaming] Fixes obsolete code
1 parent 96bdffe commit e8fe75e

File tree

1 file changed

+1
-5
lines changed

1 file changed

+1
-5
lines changed

flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/sink/writer/FileWriterBucketTest.java

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -236,11 +236,7 @@ void testTableRollingOnProcessingTime(@TempDir java.nio.file.Path tmpDir) throws
236236
Path path = new Path(outDir.toURI());
237237

238238
FileSystemTableSink.TableRollingPolicy tableRollingPolicy =
239-
new FileSystemTableSink.TableRollingPolicy(
240-
false,
241-
Long.MAX_VALUE,
242-
Duration.ofMillis(20).toMillis(),
243-
Duration.ofMillis(10).toMillis());
239+
new FileSystemTableSink.TableRollingPolicy(false, Long.MAX_VALUE, 20L, 10L);
244240

245241
TestRecoverableWriter recoverableWriter = getRecoverableWriter(path);
246242
FileWriterBucket<RowData> bucket =

0 commit comments

Comments
 (0)