Re: Flink CEP Resource Utilisation Optimisation

2023-03-26 Thread simple
退订 发自我的iPhone -- Original -- From: Abhishek Singla

Re: is there any detrimental side-effect if i set the max parallelismas 32768

2023-03-14 Thread simple
退订 发自我的iPhone -- Original -- From: Tony Wei https://nightlies.apache.org/flink/flink-docs-master/docs/dev/datastream/execution/parallel/#setting-the-maximum-parallelism > > > > -- > Best, > Hangxiang.

Re: 我使用 start-cluster.sh 运行的flink,我的jar运行一段时间后被关闭了,这个时间是不固定的

2023-02-24 Thread simple
我修改为单线程,仍然报相同的结果 发自我的iPhone -- 原始邮件 -- 发件人: Shammon FY

Re: RE: Re: Re: Should we always mark ValueState as "transient" forRichFunctions

2023-02-24 Thread simple
稍等,我看一下您的反馈 发自我的iPhone -- Original -- From: Zhongpu Chen https://github.com/apache/flink-training/blob/master/rides-and-fares/src/solution/java/org/apache/flink/training/solutions/ridesandfares/RidesAndFaresSolution.java > > > > > > > > [2] > > > > > > > >

?????? start-cluster.sh ??????flink??????jar??????????????????????????????????????????

2023-02-24 Thread simple
2023-02-24 16:05:26,104 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: Custom Source (1/1) (9644f5bc58ed204c6d31bb133156fa95_bc764cd8ddf7a0cff126f51c16239658_0_0) switched from RUNNING to CANCELING. 2023-02-24 16:05:26,108 INFO  org.apache.flink.runtime.executi

?????? start-cluster.sh ??????flink??????jar??????????????????????????????????????????

2023-02-24 Thread simple
2023-02-24 16:05:26,104 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: Custom Source (1/1) (9644f5bc58ed204c6d31bb133156fa95_bc764cd8ddf7a0cff126f51c16239658_0_0) switched from RUNNING to CANCELING. 2023-02-24 16:05:26,108 INFO  org.apache.flink.runtime.executi