Hi.
In Flink jobs running 1.18 I see the error below sometimes. I Can see the same
problem has been reported and fixed I 1.14
Anyone have an idea how to debug and/or work around this problem?
java.lang.IllegalArgumentException: Time should be non negative
at
org.apache.flink.util.Preconditions.checkArgument(Preconditions.java:138)
~[flink-dist-1.18.0.jar:1.18.0]
at
org.apache.flink.runtime.throughput.ThroughputCalculator.calculateThroughput(ThroughputCalculator.java:80)
~[flink-dist-1.18.0.jar:1.18.0]
at
org.apache.flink.runtime.throughput.ThroughputCalculator.calculateThroughput(ThroughputCalculator.java:71)
~[flink-dist-1.18.0.jar:1.18.0]
at
org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.triggerDebloating(SingleInputGate.java:450)
~[flink-dist-1.18.0.jar:1.18.0]
at
org.apache.flink.runtime.taskmanager.InputGateWithMetrics.triggerDebloating(InputGateWithMetrics.java:90)
~[flink-dist-1.18.0.jar:1.18.0]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.debloat(StreamTask.java:843)
~[flink-dist-1.18.0.jar:1.18.0]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$null$5(StreamTask.java:834)
~[flink-dist-1.18.0.jar:1.18.0]
at
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.runThrowing(StreamTaskActionExecutor.java:50)
~[flink-dist-1.18.0.jar:1.18.0]
at
org.apache.flink.streaming.runtime.tasks.mailbox.Mail.run(Mail.java:90)
~[flink-dist-1.18.0.jar:1.18.0]
at
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMail(MailboxProcessor.java:398)
~[flink-dist-1.18.0.jar:1.18.0]
at
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMailsWhenDefaultActionUnavailable(MailboxProcessor.java:367)
~[flink-dist-1.18.0.jar:1.18.0]
at
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMail(MailboxProcessor.java:352)
~[flink-dist-1.18.0.jar:1.18.0]
at
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:229)
~[flink-dist-1.18.0.jar:1.18.0]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:858)
~[flink-dist-1.18.0.jar:1.18.0]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:807)
~[flink-dist-1.18.0.jar:1.18.0]
at
org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:953)
~[flink-dist-1.18.0.jar:1.18.0]
at
org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:932)
[flink-dist-1.18.0.jar:1.18.0]
at
org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:746)
[flink-dist-1.18.0.jar:1.18.0]
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:562)
[flink-dist-1.18.0.jar:1.18.0]
at java.lang.Thread.run(Unknown Source) [?:?]
Med venlig hilsen / Best regards
Lasse Nedergaard
