update Flink program with new flink code