Dear Yuxia,
thank you for your answer! This is also our conclusion and my colleague has
already proposed this feature.
Best regards,
Tobias
- Ursprüngliche Mail -
Von: "yuxia"
An: "Dr. Tobias Fröhlich"
CC: "User" , "dev"
Gesendet: Monta
uiresStableInput' [1], the implementation in Flink is as I
described above.
Jan
[1]
https://beam.apache.org/releases/javadoc/2.44.0/org/apache/beam/sdk/transforms/DoFn.RequiresStableInput.html
On 2/14/23 13:23, Tobias Fröhlich wrote:
> Dear flink team,
>
> I am facing the following problem: I would ne
st for a future release, where the
global commit method can be implemented in a way that the user has access to
the runtimeContext?
Best regards and thanks in advance
Tobias Fröhlich
an easier way to get the watermarks from the
writer to the global committer? If not, is it justified to propose a feature
request?
Best regards and thanks in advance
Tobias Fröhlich
