Re: how can I name a sink?

2016-10-17 Thread
More information. my code are like this: [image: 内嵌图片 1] and I find I can name a sink by change code like this : [image: 内嵌图片 2] sorry for my reckless behavior. 2016-10-17 17:48 GMT+08:00 侯林蔚 : > hi >I make a flink topology and run it on my dev-cluster. >but I find somethi

how can I name a sink?

2016-10-17 Thread
hi I make a flink topology and run it on my dev-cluster. but I find something on the picture as follow: [image: 内嵌图片 1] all my sinks are unnamed , is there any method to name a sink? thank you very much.

can Flink use multi "addSink"?

2016-09-26 Thread
hello, I am a green hand with Flink, and I want to build a topology with streaming api like this: datastream.fliter(new Myfilter()).addSink(new Mysink()).map(new MyMap()).addSink(MySink2()) can Flink support operations like this? Hope for your reply sincerely. thx.