107.5. Flink DataStream Callback