https://issues.apache.org/jira/browse/FLINK-25454
On 23/08/2022 04:54, Liting Liu (litiliu) wrote:
Hi, we are using 1.14.3, but got "Time should be non negative" after
the job has been running for days.
What should i do to get rid of this Exception? Do i have to disable
the network-debloating feature?
Does it's caused by System.currentTimeMillis doesn't always return a
value bigger than before?
java.lang.IllegalArgumentException: Time should be non negative
at
org.apache.flink.util.Preconditions.checkArgument(Preconditions.java:138)
~[flink-dist_2.11-1.14.3.jar:1.14.3]
at
org.apache.flink.runtime.throughput.ThroughputEMA.calculateThroughput(ThroughputEMA.java:44)
~[flink-dist_2.11-1.14.3.jar:1.14.3]
at
org.apache.flink.runtime.throughput.ThroughputCalculator.calculateThroughput(ThroughputCalculator.java:80)
~[flink-dist_2.11-1.14.3.jar:1.14.3]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.debloat(StreamTask.java:792)
~[flink-dist_2.11-1.14.3.jar:1.14.3]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$null$4(StreamTask.java:784)
~[flink-dist_2.11-1.14.3.jar:1.14.3]
at
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.runThrowing(StreamTaskActionExecutor.java:50)
~[flink-dist_2.11-1.14.3.jar:1.14.3]
at
org.apache.flink.streaming.runtime.tasks.mailbox.Mail.run(Mail.java:90)
~[flink-dist_2.11-1.14.3.jar:1.14.3]
