Hi Alexey, Thanks for your reply, could you also share logs during normal restoring just as I wrote in previous thread so that I could compare.
Best Yun Tang ________________________________ From: Alexey Trenikhun <yen...@msn.com> Sent: Wednesday, March 17, 2021 13:55 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 Hi Yun, I'm attaching shorter version of log, looks like full version didn't come through Thanks, Alexey ________________________________ From: Yun Tang <myas...@live.com> Sent: Tuesday, March 16, 2021 8:05 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 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/
