xiaogang zhou created FLINK-17878:
-------------------------------------
Summary: StreamingFileWriter watermark attribute is transient,
this might be different with origin value
Key: FLINK-17878
URL: https://issues.apache.org/jira/browse/FLINK-17878
Project: Flink
Issue Type: Improvement
Components: API / DataStream
Affects Versions: 1.11.0
Reporter: xiaogang zhou
StreamingFileWriter has a
private transient long currentWatermark = Long.MIN_VALUE;
in case developer wants to create a custom bucket assigner, it will receive a
currentWatermark as 0, this might be conflict with the original flink approach
to handle a min_long.
should we remove the transient key word?
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
