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...
http://issues.apache.org/jira/browse/FLINK-9507    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...
http://issues.apache.org/jira/browse/FLINK-9620    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...
http://issues.apache.org/jira/browse/FLINK-9443    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 ...
http://issues.apache.org/jira/browse/FLINK-10158    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...
http://issues.apache.org/jira/browse/FLINK-10343    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 ...
http://issues.apache.org/jira/browse/FLINK-9883    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 ...
http://issues.apache.org/jira/browse/FLINK-9687    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...
http://issues.apache.org/jira/browse/FLINK-10996    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