In that case, the most possible cause would be
https://issues.apache.org/jira/browse/FLINK-16313, which is included in
Flink 1.10.1 (to be released)
The release candidates for Flink 1.10.1 is currently ongoing, would it be
possible for you to try that out and see if the error still occurs?
On
Thanks Gordon and Seth for the reply.
So.. the main project contains the below flink dependencies...
And the state processor project contains the following:
1.9.0
At the first sight I may say all the libraries match to 1.9.0 flink
libraries within both projects.
--
Sent from:
Gordon is correct. Additionally, if you are using flink 1.10 you may be
running into a known bug that has been resolved in 1.10.1 which will be
released soon.
Seth
https://issues.apache.org/jira/browse/FLINK-16313
On Fri, May 8, 2020 at 5:19 AM Tzu-Li (Gordon) Tai
wrote:
> Hi,
>
> The last
Hi,
The last time I saw this error, was that there was a mismatch in the used
flink-state-processor-api version and other core Flink dependencies.
Could you confirm that?
Also, are you seeing this assertion error consistently, or only
occasionally?
cc'ing Seth, maybe he has other clues on the
No one? :)
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
1.9/dev/libs/state_processor_api.html#modifying-savepoints>
However when I execute locally using macOS it throws me an error related to
assertion failure - apparently when writing the Savepoint.
Assertion failed: (last_ref), function ~ColumnFamilySet, file
db/column_family.cc, line 1238.
