clear query| facets| time Search criteria: .   Results from 1 to 10 from 72 (0.0s).
Loading phrases to help you
refine your search...
[Discuss] Semantics of event time for state TTL - Flink - [mail # user]
...Hi, AndreyI think ttl state has another scenario to simulate the slide window with theprocess function. User can define a state to store the data with the latest1 day. And trigger calculate ...
   Author: aitozi , 2019-04-09, 15:18
[FLINK-9507] Introduce ReduceFunction to CEP to minor the cost for IterativeCondition - Flink - [issue]
...When we use the cep to describe a condition about the events that has been matched, we have to call the method  "getEventsForPattern" to extract the partly matched elements from the sha...    Author: aitozi , 2019-03-11, 13:01
[FLINK-9620] Add an alternative option to choose when deal with eventtime cep - Flink - [issue]
...Now when deal with eventtime, it use the elementQueue to buffer event to work with the out of order data, I think its ok. But when the key is very  fragmented, every time the watermark advan...    Author: aitozi , 2019-02-28, 15:30
[FLINK-9443] Remove unused parameter in StreamGraphHasherV2 - Flink - [issue]
...After Flink1.2 it used StreamGraphHasherV2 to generate hashes, The method generateNodeLocalHash dont use the information like (parallel, userFunction) now, so the parameter should be removed...    Author: aitozi , 2019-02-28, 14:12
[FLINK-10158] The DataOutputSerializer may consume excessive memory - Flink - [issue]
...I found that the dataOutputSerializer clear the intermediate buffer when the buffer exceed the 5M (as a fixed configuration), But when we encountered the rebalance or keyByPartition and the ...    Author: aitozi , 2019-02-28, 13:20
[FLINK-10343] Expose setCurrentKey method to streamRuntimeContext - Flink - [issue]
...when we use reducing state / aggregating keyed state and so on , we have to read value from state backend and update the value with userFunction and then put back to state backend. If we can...    Author: aitozi , 2019-02-28, 11:15
[FLINK-9883] Filter the target window to calculate when deal with slidewindow - Flink - [issue]
...When the SlideWindow deal with the ContinuousProcessingTimeTrigger or ContinuousEventTimeTrigger will trigger all the related slide window to process, but when user only care about the data ...    Author: aitozi , 2019-02-28, 11:14
[FLINK-9687] Delay the state fetch only when the triggerResult is fire - Flink - [issue]
...When the window operator is fired by the event timer or processing timer, it fetch the state content first. I think it only need to fetch the content from windowState when the triggerResult ...    Author: aitozi , 2019-02-28, 11:14
[FLINK-10996] Enable state ttl in cep - Flink - [issue]
...In flink cep, although the within clause can clean up the data when data is expire. But If the specific key data never come again, the partial matched data will not be deleted again which wi...    Author: aitozi , 2019-02-25, 12:32
Production readiness - Flink - [mail # user]
...Hi, AndreyI have another question that if i do not set the maximum parallelismfirst(which be set to 128 by default), and then rescale to a parallelismbigger than 128. In this scenario,will t...
   Author: aitozi , 2019-02-14, 02:50