[FLINK-1196] [streaming] Added abstract fault tolerance layer