clear query| facets| time Search criteria: .   Results from 1 to 10 from 63 (0.0s).
Loading phrases to help you
refine your search...
[expand - 1 more] - A little doubt about the blog A Deep To Flink's NetworkStack - Flink - [mail # user]
...Hi Zhijiang,Thanks for your explanation, I have understood it. My former thoughts waswrong, the real TCP channel was established whencreatePartitionRequestClient. Thanks,Aitozi--Sent from: h...
   Author: aitozi , 2019-06-17, 04:55
[FLINK-12859] ClassNotFoundException during MapRFs init - Flink - [issue]
...I was running mvn clean package locally on master branch to pass all the test case, I ran into the ClassNotFoundException as shown below, but I check the [flink-mapr-fs][pom.xml&...
http://issues.apache.org/jira/browse/FLINK-12859    Author: Aitozi , 2019-06-16, 04:24
Timeout about local test case - Flink - [mail # user]
...Hi community,When I run mvn clean install locally (branch master) the test case alwaysfailed with bundle timeout exception, I am doubt why this failed? And alsoan ip  PS: I run the case...
   Author: aitozi , 2019-06-15, 11:21
[FLINK-12637] Add metrics for floatingBufferUsage and exclusiveBufferUsage for credit based mode - Flink - [issue]
...Described here...
http://issues.apache.org/jira/browse/FLINK-12637    Author: Aitozi , 2019-06-07, 13:00
[FLINK-9431] Introduce TimeEnd State to flink cep - Flink - [issue]
...Now flink cep have no support to reach a Final State upon past some time. if i use a pattern like Pattern.begin('A').notFollowedBy("B"), if i want A element be emitted after 5minutes, i have...
http://issues.apache.org/jira/browse/FLINK-9431    Author: aitozi , 2019-05-15, 06:47
[FLINK-12492] Minor optimize the cep operator by avoiding unnecessary copy - Flink - [issue]
...When use with rocksdbbackend, we can skip the copy of input events. But to make this more constraint, i add a method in the KeyedStateBackend interface to make this still work id there is ad...
http://issues.apache.org/jira/browse/FLINK-12492    Author: aitozi , 2019-05-12, 15:36
[expand - 1 more] - RocksDB backend with deferred writes? - Flink - [mail # user]
...Hi,David Before I open an issue about this and @Andrey Zagrebin @Aljoscha Krettek suggested me to extends the AbstractStreamOperator to custom the operator operation on state or extends...
   Author: aitozi , 2019-04-29, 04:57
Warning from [EMAIL PROTECTED] - Flink - [mail # dev]
...Hi, dev-owner:I'm not quite understand the mail, can you tell me what's it point to ?Thanks,AitoziOn 2019/4/27, 1:40 AM, "[EMAIL PROTECTED]"  wrote:    Hi! This is the ezmlm ...
   Author: aitozi , 2019-04-27, 08:21
[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-04-24, 01:55
[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