APSHOT.jar/flink-dist_2.12-1.13.5.jar);
I'd suggest to resolve that first and see if the error persists.
On 23/05/2022 14:32, 李诗君 wrote:
flink version: 1.13.5
java code:
StreamExecutionEnvironment env =
StreamExecutionEnvironment.getExecutionEnvironment();
EnvironmentSetting
flink version: 1.13.5
java code:
StreamExecutionEnvironment env =
StreamExecutionEnvironment.getExecutionEnvironment();
EnvironmentSettings settings = EnvironmentSettings.newInstance()
.useBlinkPlanner()
.inStreamingMode()
.build();
n
>
> On Fri, Dec 10, 2021 at 3:41 AM 李诗君 wrote:
>>
>> I am trying to upgrade my flink cluster version from 1.13.1 to 1.14.0 , I
>> did like below steps:
>>
>> 1. savepoint running tasks in version1.13.1
>> 2. stop tasks and upgrade cluster version t
I am trying to upgrade my flink cluster version from 1.13.1 to 1.14.0 , I did
like below steps:
1. savepoint running tasks in version1.13.1
2. stop tasks and upgrade cluster version to 1.14.0
3. recover tasks with savepoints
and this happened:
java.lang.RuntimeException: Error while getting
