clear query| facets| time Search criteria: .   Results from 1 to 10 from 57 (0.0s).
Loading phrases to help you
refine your search...
[FLINK-10374] [Map State] Let user value serializer handle null values - Flink - [issue]
...Prior to Flink 2.0, value serializer in map state does not rely on user serializer to handle null value. Map serializer always prepends the serialized value with one byte boolean flag which ...    Author: Andrey Zagrebin , 2018-09-20, 08:19
[expand - 1 more] - Window operator schema evolution - savepoint deserialization fail - Flink - [mail # user]
...Hi Zdenek,the schema evolution can be tricky in general. I would suggest to plan possible schema extensions in advance, use more custom serialisation and make sure that it supports the requi...
   Author: Andrey Zagrebin , 2018-09-17, 09:22
[FLINK-10325] [State TTL] Refactor TtlListState to use only loops, no java stream API for performance - Flink - [issue]    Author: Andrey Zagrebin , 2018-09-16, 05:00
[FLINK-9360] HA end-to-end nightly test takes more than 15 min in Travis CI - Flink - [issue]
...We have not discussed how long the nightly tests should run. Currently overall testing build time is around the limit of free Travis CI VM (50 min)....    Author: Andrey Zagrebin , 2018-09-15, 21:21
Can rocksDBBackend handle rescaling? - Flink - [mail # user]
...Hi Jiayi Liao,I have answered the similar question here:
   Author: Andrey Zagrebin , 2018-09-14, 13:01
Aggregator State in Keyed Windowed Stream - Flink - [mail # user]
...Hi Ning,> Back to my first question, is the accumulator state backed by RocksDB state backend? If so, I don’t need to use rich function for the aggregate function.the answer is yes, it is...
   Author: Andrey Zagrebin , 2018-09-10, 13:40
[ANNOUNCE] New committer Gary Yao - Flink - [mail # dev]
...Congratulations Gary!> On 7 Sep 2018, at 15:45, Stefan Richter  wrote:> > Congrats Gary!> >> Am 07.09.2018 um 15:14 schrieb Till Rohrmann :>> >> Hi everybo...
   Author: Andrey Zagrebin , 2018-09-07, 13:59
RocksDB Number of Keys Metric - Flink - [mail # user]
...Hi,afaik, the option is not exposed according to the current state of source code.I can see it to be useful and technically possible using:db.getLongProperty(stateColumnFamilyHandle, "rocksd...
   Author: Andrey Zagrebin , 2018-09-06, 09:45
Using Managed Keyed State - Flink - [mail # user]
...Hi,If you ask about keyed state, you probably mean ListState, because in any case List is just java object for a concrete value of state. ListState is also scoped by current record key as Va...
   Author: Andrey Zagrebin , 2018-08-31, 12:29
Usage of "onTime" in ProcessFunction - Flink - [mail # user]
...Hi,the timers are scoped to the current key when you apply a processing function to a KeyedStream.If you register more than one timer for a particular key and timestamp, you will get only on...
   Author: Andrey Zagrebin , 2018-08-31, 12:20