Re: Unit Test for KeyedProcessFunction with out-of-core state

Trenikhun Cc: Dawid Wysakowicz ; Flink User Mail List Subject: Re: Unit Test for KeyedProcessFunction with out-of-core state The new backend would be for unit tests (instead of a RocksDB mock). It's kind of the mock for out-of-core behavior that you initially requested. To use rocksDB in an IT

Re: Unit Test for KeyedProcessFunction with out-of-core state

--- > *From:* Arvid Heise > *Sent:* Monday, September 14, 2020 4:26:47 AM > *To:* Dawid Wysakowicz > *Cc:* Alexey Trenikhun ; Flink User Mail List < > user@flink.apache.org> > *Subject:* Re: Unit Test for KeyedProcessFunction with out-of-core state > &

Re: Unit Test for KeyedProcessFunction with out-of-core state

KeyedProcessFunction with out-of-core state Hi Alexey, Definition of test levels are always a bit blurry when writing tests for a data processing framework, but I'm convinced that in your case, you should rather think in terms of integration tests than unit tests: * Unit test should really

Re: Unit Test for KeyedProcessFunction with out-of-core state

gt; Thanks, > Alexey > > -- > *From:* Tzu-Li (Gordon) Tai > *Sent:* Friday, September 4, 2020 12:35:48 AM > *To:* Alexey Trenikhun > *Cc:* Flink User Mail List > *Subject:* Re: Unit Test for KeyedProcessFunction with out-of-core state > >

Re: Unit Test for KeyedProcessFunction with out-of-core state

-- > *From:* Tzu-Li (Gordon) Tai > *Sent:* Friday, September 4, 2020 12:35:48 AM > *To:* Alexey Trenikhun > *Cc:* Flink User Mail List > *Subject:* Re: Unit Test for KeyedProcessFunction with out-of-core state >   > Hi Alexey, > > Is there a specific reason why you

Re: Unit Test for KeyedProcessFunction with out-of-core state

, September 4, 2020 12:35:48 AM To: Alexey Trenikhun Cc: Flink User Mail List Subject: Re: Unit Test for KeyedProcessFunction with out-of-core state Hi Alexey, Is there a specific reason why you want to test against RocksDB? Otherwise, in Flink tests we use a `KeyedOneInputStreamOperatorTestHarness

Re: Unit Test for KeyedProcessFunction with out-of-core state

Hi Alexey, Is there a specific reason why you want to test against RocksDB? Otherwise, in Flink tests we use a `KeyedOneInputStreamOperatorTestHarness` [1] that allows you to wrap a user function and eliminate the need to worry about setting up heavy runtime context / dependencies such as the sta

Unit Test for KeyedProcessFunction with out-of-core state

Hello, I want to unit test KeyedProcessFunction which uses with out-of-core state (like rocksdb). Does Flink has mock for rocksdb, which can be used in unit tests ? Thanks, Alexey