chnage delay to 1 ms

Signed-off-by: Shwetha N <[email protected]>
pravega · Oct 20, 2023 · f1a5f1d · f1a5f1d
1 parent d6f876f
commit f1a5f1d
Show file tree

Hide file tree

Showing 3 changed files with 12 additions and 12 deletions.
diff --git a/...sensor-collector/src/main/java/io/pravega/sensor/collector/file/LogFileIngestService.java b/...sensor-collector/src/main/java/io/pravega/sensor/collector/file/LogFileIngestService.java
@@ -149,13 +149,13 @@ protected void doStart() {
                 TimeUnit.MILLISECONDS);
         /*
         Submits a periodic action that becomes enabled immediately  for the first time,
-        and subsequently with the delay of 1 milliseconds(0 is not accepted) between the termination of one execution and the commencement of the next
+        and subsequently with the delay of 1 milliseconds between the termination of one execution and the commencement of the next
         ie immediately after completion of first action.
          */
         processFileTask = executor.scheduleWithFixedDelay(
                 this::processLogFiles,
                 0,
-                0,
+                1,
                 TimeUnit.MILLISECONDS);
         notifyStarted();
     }

diff --git a/...collector/src/main/java/io/pravega/sensor/collector/parquet/ParquetFileIngestService.java b/...collector/src/main/java/io/pravega/sensor/collector/parquet/ParquetFileIngestService.java
@@ -148,18 +148,18 @@ protected void processParquetFiles() {
         log.trace("processParquetFiles: END");
     }
 
-    /*
-        Submits a periodic action that becomes enabled immediately  for the first time,
-        and subsequently with the delay of 1 milliseconds(0 is not accepted) between the termination of one execution and the commencement of the next
-        ie immediately after completion of first action.
-         */
     @Override
     protected void doStart() {
         watchFileTask = executor.scheduleAtFixedRate(
                 this::watchParquetFiles,
                 0,
                 getIntervalMs(),
                 TimeUnit.MILLISECONDS);
+        /*
+        Submits a periodic action that becomes enabled immediately  for the first time,
+        and subsequently with the delay of 1 milliseconds between the termination of one execution and the commencement of the next
+        ie immediately after completion of first action.
+        */
         processFileTask = executor.scheduleWithFixedDelay(
                 this::processParquetFiles,
                 0,

diff --git a/...sor-collector/src/main/java/io/pravega/sensor/collector/rawfile/RawFileIngestService.java b/...sor-collector/src/main/java/io/pravega/sensor/collector/rawfile/RawFileIngestService.java
@@ -141,18 +141,18 @@ protected void processRawFiles() {
         log.trace("processRawFiles: END");
     }
 
-    /*
-        Submits a periodic action that becomes enabled immediately  for the first time,
-        and subsequently with the delay of 1 milliseconds(0 is not accepted) between the termination of one execution and the commencement of the next
-        ie immediately after completion of first action.
-         */
     @Override
     protected void doStart() {
         watchFileTask = executor.scheduleAtFixedRate(
                 this::watchRawFiles,
                 0,
                 getIntervalMs(),
                 TimeUnit.MILLISECONDS);
+        /*
+        Submits a periodic action that becomes enabled immediately  for the first time,
+        and subsequently with the delay of 1 milliseconds between the termination of one execution and the commencement of the next
+        ie immediately after completion of first action.
+        */
         processFileTask = executor.scheduleWithFixedDelay(
                 this::processRawFiles,
                 0,