Details
-
Bug
-
Status: Resolved
-
P0
-
Resolution: Fixed
-
2.1.0
-
None
Description
While working on BEAM-1779 I noticed this bug because these tests now test checkpointing/restore of the source operators.
The fix is to properly implement read() and write() and change the compatibility-check logic a bit.
Attachments
Issue Links
- relates to
-
BEAM-2807 NullPointerException during checkpoint on FlinkRunner
- Resolved