Re: Lack of KeyedBroadcastStateBootstrapFunction

2020-03-30 Thread Mark Niehe
Hi Gordan and Seth, Thanks for explanation and opening up the ticket. I'll add some details in the ticket to explain what we're trying to do which will hopefully add some context. -- <http://segment.com/> Mark Niehe · Software Engineer Integrations <https://segment.com

Lack of KeyedBroadcastStateBootstrapFunction

2020-03-23 Thread Mark Niehe
ction. Because these are the only two options, it's not possible to bootstrap both keyed and broadcast state for the same operator. Are there any plans to add that functionality or did I miss it entirely when going through the API docs? Thanks, -- <http://segment.com/> Mark Niehe · S

State Processor API Keyed State

2020-02-18 Thread Mark Niehe
eration.java:141) at org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackendBuilder.build(RocksDBKeyedStateBackendBuilder.java:270) ... 13 more Has anyone come across this before and figured out a fix? Any help you can give would be greatly appreciated! Thanks, -- <http://segment.com/> Mark Niehe · Software En