Page History

...

• STREAMING:
  • execution.schedule-mode = EAGER
  • execution.shuffle-mode = ALL_EDGES_PIPELINED
  • execution.incremental-updates = true
• BATCH:
  • execution.schedule-mode = LAZY_FROM_SOURCSE
  • execution.shuffle-mode = POINTWISE_EDGES_PIPELINED
  • execution.incremental-updates = false

We propose to introduce three new settings pipeline.processing-time.allow, pipeline.processing-time.end-of-input, pipeline.windowing.triggers.allow with these defaults:

• STREAMING
  • pipeline.processing-time.allow: ALLOW
  • pipeline.processing-time.end-of-input: FIRE_AND_QUIESCE
  • pipeline.windowing.triggers.allow: ALLOW
• BATCH
  • pipeline.processing-time.allow: FAIL
  • pipeline.processing-time.end-of-input: IGNORE
  • pipeline.windowing.triggers.allow: IGNORE

We want to make EventTime the new default StreamTimeCharacteristic.

...