Add test to modify a processor and add a processing time tumblingWindow

    • Type: Task
    • Resolution: Unresolved
    • Priority: Major - P3
    • None
    • Affects Version/s: None
    • Component/s: None
    • Atlas Streams
    • None
    • 3
    • TBD
    • None
    • None
    • None
    • None
    • None
    • None
    • None

      We currently have a test in modify.js that starts a SP with initialSync=true, then after the collectionCopy is over, it modifies the SP to set initialSync=false and then adds a tumbling window to the modified pipeline.

      When the above test is modified so that the added tumbling window is a processing time window, it causes an off-by-one error where the last message in inputAfterModifyBeforeStart is not processed as part of the window.

      Investigate this behavior and add a testcase like the following to test the addition of a tumbling window with processingTIme mode.

      ```
      modifiedPipeline: [
      {$replaceRoot: {newRoot: "$fullDocument"}},
      {
      $tumblingWindow: {
      interval:

      {unit: "second", size: NumberInt(3)}

      ,
      pipeline: [{$group: {_id: "group1", sum: {$sum: "$c"}}}]
      }
      },
      {$set: {initialSync: {$meta: "stream.source.initialSync"}}},
      ],
      ```

            Assignee:
            Unassigned
            Reporter:
            Mayuresh Kulkarni
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

              Created:
              Updated: