Hi,
it's not possible to access the key in the open method because without an element that is being processed there is no key. The user function is being used to produce elements of different keys that are being processed on the same shard (instance of a parallel operator). You can get the key manually by inspecting the element in the invoke() method of your sink.

Cheers,
Aljoscha

On Sat, 24 Dec 2016 at 17:15 Telco Phone <telco5@yahoo.com> wrote:
I am trying to access the keyBy value in the "open" method in a RichSink


Is there a way to access the actual keyBy value in the RichSink ?



DataStream<TestRecord> stream =
env.addSource(new FlinkKafkaConsumer08<>("test", schema, properties)
).setParallelism(1).keyBy("partition");