Details
-
Bug
-
Status: Closed
-
Blocker
-
Resolution: Fixed
-
1.2.0, 1.2.1, 1.3.0, 1.3.1
-
None
Description
FlinkKafkaProducer010 doesn't implement CheckpointedFunction interface. This means, when it's used like a "regular sink function" (option a from the java doc) it will not flush the data on "snapshotState" as it is supposed to.