| commit | 4aac946624eed8a0b9f334acad550de7e2e3ad7e | [log] [tgz] |
|---|---|---|
| author | Igal Shilman <igalshilman@gmail.com> | Tue May 05 22:27:02 2020 +0200 |
| committer | Tzu-Li (Gordon) Tai <tzulitai@apache.org> | Fri May 15 18:52:38 2020 +0800 |
| tree | 17c330a7341e25e430ec0c3f928b5525ec7f921a | |
| parent | b3f6b844e9f9b568b7c94f68b7cfdf758e8e66dc [diff] |
[FLINK-17533] Expose checkpointId from barrier messages This commit changes the boolean method isBarrierMessage() to return an OptionalLong that would carry the checkpointId when the message is a checkpoint barrier.