Hi everybody,
I think I'm in the same issue above described in
https://issues.apache.org/jira/browse/FLINK-6291 . Flink1-6.4
I have had this savepoint with a timer service belonging to a process
function. When I restore a new job w/o the former process function ti fails
in the following way.
What i
Hello Timo,
we found that the problem was not related to a timer but to an hardware
issue in the production system.
On the other hand the NPE exception in HeapInternalTimerService in the
testing system was due to
the fact the savepoint was created by a different version of the
application; definite
Hello Timo,
thanks for the response.
We are still investigating in the production system but in test we get now
this exception that seems very much related to the issue 6291.
java.lang.Exception: Could not perform checkpoint 13468 for operator
Aggregator -> Sink: HBase (1/1).
at
org.ap
Hi Alberto,
do you get exactly the same exception? Maybe you can share some logs
with us?
Regards,
Timo
Am 25.05.18 um 13:41 schrieb Alberto Mancini:
Hello,
I think we are experiencing this issue:
https://issues.apache.org/jira/browse/FLINK-6291
In fact we have a long running job that is un
Hello,
I think we are experiencing this issue:
https://issues.apache.org/jira/browse/FLINK-6291
In fact we have a long running job that is unable to complete a checkpoint
and so we are unable to create a savepoint.
I do not really understand from 6291 how the timer service has been
removed in my
