clear query| facets| time Search criteria: .   Results from 1 to 10 from 38 (0.0s).
Loading phrases to help you
refine your search...
[DISCUSS] FLIP-27: Refactor Source Interface - Flink - [mail # dev]
...Hi Becket,Thanks for updating the progress!I have a question about the #OperatorCoordinator. Will there be any communication between different #OperatorCoordinators (or in the future plan)? ...
   Author: bupt_ljy , 2019-12-04, 10:53
ProcessFunction collect and close, when to use? - Flink - [mail # user]
...Hi Shuwen,> When to call close() ? After every element processed? Or on ProcessFunction.close() ? Or never to use it? IMO, the #close() function is used to manage the lifecycle of #Collec...
   Author: bupt_ljy , 2019-11-29, 05:45
CoGroup SortMerger performance degradation from 1.6.4 - 1.9.1? - Flink - [mail # user]
...Hi,I’ve met the exactly same problem recently and solved it in Piotr’s way. @zhijiang, I didn’t see any oom error thrown by JVM (I’m not sure this can be thrown if yarn decides to kill it in...
   Author: bupt_ljy , 2019-11-27, 03:50
[ANNOUNCE] Jark Wu is now part of the Flink PMC - Flink - [mail # dev]
...Congratulations Jark!Best,Jiayi Liao Original Message Sender: Yun GaoRecipient: devDate: Friday, Nov 8, 2019 18:37Subject: Re: [ANNOUNCE] Jark Wu is now part of the Flink PMCCongratulat...
   Author: bupt_ljy , 2019-11-08, 11:21
[expand - 1 more] - RocksDB state on HDFS seems not being cleanned up - Flink - [mail # user]
...This should be sent to user mailing list. Moving it here... Original Message Sender: bupt_ljyRecipient: devDate: Tuesday, Nov 5, 2019 21:13Subject: Re: RocksDB state on HDFS seems not b...
   Author: bupt_ljy , 2019-11-05, 13:15
[expand - 1 more] - Finite source without blocking save-points - Flink - [mail # user]
...Oh the parallelism problem didn’t bother me because we used to set the parallelism of rule source to be one :o). Maybe a more elegant way is hashing the rule emitting by #RuntimeContext#getI...
   Author: bupt_ljy , 2019-11-04, 15:55
[DISCUSS] Semantic and implementation of per-job mode - Flink - [mail # user]
...Hi all,Firstly thanks @tison for bring this up and strongly +1 for the overall design. I’d like to add one more example of "multiple jobs in one program" with what I’m currently working on. ...
   Author: bupt_ljy , 2019-11-01, 03:17
[ANNOUNCE] Becket Qin joins the Flink PMC - Flink - [mail # dev]
...Congratulations Becket!Best,Jiayi Liao Original Message Sender: Biao LiuRecipient: devDate: Tuesday, Oct 29, 2019 12:10Subject: Re: [ANNOUNCE] Becket Qin joins the Flink PMCCongrats Bec...
   Author: bupt_ljy , 2019-10-29, 04:25
[DISCUSS] Introduce a location-oriented two-stage query mechanism toimprove the queryable state. - Flink - [mail # dev]
...Hi vino,+1 for improvement on queryable state feature. This reminds me of the state-processing-api module, which is very helpful when we analyze state in offline. However currently we don’t ...
   Author: bupt_ljy , 2019-10-24, 13:04
Setting environment variables of the taskmanagers (yarn) - Flink - [mail # user]
...Hi Richard,You can use dynamic properties to add your environmental variables.Set jobmanager env:e.g. -Dcontainerized.master.env.GOOGLE_APPLICATION_CREDENTIALS=xyzSet taskmanager env:e.g. -D...
   Author: bupt_ljy , 2019-09-24, 15:52