Re: dynamic add sink to flink

2017-06-12 Thread Tzu-Li (Gordon) Tai
, but it will cost too much time to start the flink job if we want to add some other kafka sink to the flink, so if there any way to dynamic add sink to flink or just start the flink job faster? The reason of slow start flink job I think is the lots of kafka sink. We now use the demo code like

dynamic add sink to flink

2017-06-09 Thread qq
Hi: we use flink as a router to our kafka, we read from one kafka and to a lot of diffrent kafka and topic, but it will cost too much time to start the flink job if we want to add some other kafka sink to the flink, so if there any way to dynamic add sink to flink or just start the flink