[incubator-seatunnel] branch dev updated: [Improvement][flink-connector-file] Updated default rollover interval constant name (#1616)

[kirs]

This is an automated email from the ASF dual-hosted git repository.

kirs pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new 3145c68  [Improvement][flink-connector-file] Updated default rollover 
interval constant name (#1616)
3145c68 is described below

commit 3145c688a649f1ed0f5d03a118de8fa4a27071aa
Author: mans2singh <mans2si...@users.noreply.github.com>
AuthorDate: Wed Mar 30 06:56:23 2022 -0400

    [Improvement][flink-connector-file] Updated default rollover interval 
constant name (#1616)
---
 .../src/main/java/org/apache/seatunnel/flink/file/sink/FileSink.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/file/sink/FileSink.java
 
b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/file/sink/FileSink.java
index 6972c2b..a206093 100644
--- 
a/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/file/sink/FileSink.java
+++ 
b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/file/sink/FileSink.java
@@ -61,7 +61,7 @@ public class FileSink implements FlinkStreamSink, 
FlinkBatchSink {
     private static final String DEFAULT_TIME_FORMAT = "yyyyMMddHHmmss";
     // *********************** For stream mode config ************************
     private static final String ROLLOVER_INTERVAL = "rollover_interval";
-    private static final long DEFAULE_ROLLOVER_INTERVAL = 60;
+    private static final long DEFAULT_ROLLOVER_INTERVAL = 60;
     private static final String MAX_PART_SIZE = "max_part_size";
     private static final long DEFAULT_MAX_PART_SIZE = 1024;
     private static final String PART_PREFIX = "prefix";
@@ -82,7 +82,7 @@ public class FileSink implements FlinkStreamSink, 
FlinkBatchSink {
         final DefaultRollingPolicy<Row, String> rollingPolicy = 
DefaultRollingPolicy.builder()
             .withMaxPartSize(MB * TypesafeConfigUtils.getConfig(config, 
MAX_PART_SIZE, DEFAULT_MAX_PART_SIZE))
             .withRolloverInterval(
-                
TimeUnit.MINUTES.toMillis(TypesafeConfigUtils.getConfig(config, 
ROLLOVER_INTERVAL, DEFAULE_ROLLOVER_INTERVAL)))
+                
TimeUnit.MINUTES.toMillis(TypesafeConfigUtils.getConfig(config, 
ROLLOVER_INTERVAL, DEFAULT_ROLLOVER_INTERVAL)))
             .build();
         OutputFileConfig outputFileConfig = OutputFileConfig.builder()
             .withPartPrefix(TypesafeConfigUtils.getConfig(config, PART_PREFIX, 
DEFAULT_PART_PREFIX))