You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
By default, the streaming flink executor periodically forwards ingestion time watermarks from the sources. in case no windowing is part of a flow, this generates some unnecessary traffic; we can see this traffic in flink's task tracker ui.
Before translating a euphoria flow into a flink DAG, we can analyze the flow, and determine whether sending periodic watermarks starting here (i.e. InputTranslator) is necessary. If not setting the flows streamTimeCharacteristic to "processing time" might do the trick.
The text was updated successfully, but these errors were encountered:
Since pull request #59 Flink executor runs using ingestion time characteristics. Timestamp is assigned to element implicitly by Flink in SourceFunction, not in InputTranslator anymore.
By default, the streaming flink executor periodically forwards ingestion time watermarks from the sources. in case no windowing is part of a flow, this generates some unnecessary traffic; we can see this traffic in flink's task tracker ui.
Before translating a euphoria flow into a flink DAG, we can analyze the flow, and determine whether sending periodic watermarks starting here (i.e.
InputTranslator
) is necessary. If not setting the flowsstreamTimeCharacteristic
to "processing time" might do the trick.The text was updated successfully, but these errors were encountered: