退订
发自我的iPhone
-- Original --
From: Abhishek Singla
退订
发自我的iPhone
-- Original --
From: Tony Wei https://nightlies.apache.org/flink/flink-docs-master/docs/dev/datastream/execution/parallel/#setting-the-maximum-parallelism
>
>
>
> --
> Best,
> Hangxiang.
我修改为单线程,仍然报相同的结果
发自我的iPhone
-- 原始邮件 --
发件人: Shammon FY
稍等,我看一下您的反馈
发自我的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]
> > > >
> >
> >
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
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