Hi Alexey,

I believe your exception messages are printed from Flink-1.12.2 not 
Flink-1.12.1 due to the line number of method calling.

Could you share exception message of Flink-1.12.1 when rescaling? Moreover, I 
hope you could share more logs during restoring and rescaling. I want to see 
details of key group handle [1]

[1] 
https://github.com/apache/flink/blob/dc404e2538fdfbc98b9c565951f30f922bf7cedd/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/restore/RocksDBFullRestoreOperation.java#L153

Best
________________________________
From: Alexey Trenikhun <yen...@msn.com>
Sent: Tuesday, March 16, 2021 15:10
To: Yun Tang <myas...@live.com>; Tzu-Li (Gordon) Tai <tzuli...@apache.org>; 
user@flink.apache.org <user@flink.apache.org>
Subject: Re: EOFException on attempt to scale up job with RocksDB state backend

Also restore from same savepoint without change in parallelism works fine.

________________________________
From: Alexey Trenikhun <yen...@msn.com>
Sent: Monday, March 15, 2021 9:51 PM
To: Yun Tang <myas...@live.com>; Tzu-Li (Gordon) Tai <tzuli...@apache.org>; 
user@flink.apache.org <user@flink.apache.org>
Subject: Re: EOFException on attempt to scale up job with RocksDB state backend

No, I believe original exception was from 1.12.1 to 1.12.1

Thanks,
Alexey

________________________________
From: Yun Tang <myas...@live.com>
Sent: Monday, March 15, 2021 8:07:07 PM
To: Alexey Trenikhun <yen...@msn.com>; Tzu-Li (Gordon) Tai 
<tzuli...@apache.org>; user@flink.apache.org <user@flink.apache.org>
Subject: Re: EOFException on attempt to scale up job with RocksDB state backend

Hi,

Can you scale the job at the same version from 1.12.1 to 1.12.1?

Best
Yun Tang

________________________________
From: Alexey Trenikhun <yen...@msn.com>
Sent: Tuesday, March 16, 2021 4:46
To: Tzu-Li (Gordon) Tai <tzuli...@apache.org>; user@flink.apache.org 
<user@flink.apache.org>
Subject: Re: EOFException on attempt to scale up job with RocksDB state backend

Savepoint was taken with 1.12.1, I've tried to scale up using same version and 
1.12.2

________________________________
From: Tzu-Li (Gordon) Tai <tzuli...@apache.org>
Sent: Monday, March 15, 2021 12:06 AM
To: user@flink.apache.org <user@flink.apache.org>
Subject: Re: EOFException on attempt to scale up job with RocksDB state backend

Hi,

Could you provide info on the Flink version used?

Cheers,
Gordon



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Reply via email to