We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 17e714b commit 63a33b1Copy full SHA for 63a33b1
file/file-source/src/main/java/com/dtstack/flink/sql/source/file/FileSource.java
@@ -62,7 +62,7 @@
62
public class FileSource extends AbstractRichFunction implements IStreamSourceGener<Table>, SourceFunction<Row> {
63
private static final Logger LOG = LoggerFactory.getLogger(FileSource.class);
64
65
- private static final Long METRIC_WAIT_TIME = 5L;
+ private static final Long METRIC_WAIT_TIME = 20L;
66
67
private static final String SP = File.separator;
68
0 commit comments