Thanks for you opinion on this. TwoPhaseCommitSinkFunction would probably be the best solution overall. Using this with something like Phoenix or Tephra would probably work. This always depends on checkpointing interval right?
-- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
