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
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.
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.