[ https://issues.apache.org/jira/browse/FLINK-25454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17555077#comment-17555077 ]
Piotr Nowojski commented on FLINK-25454: ---------------------------------------- I've looked into backporting this fix, but it's not that simple. The fix would have to be re-implemented, as the code has changed quite a lot between 1.14.x and 1.15.x. If someone ([~aliazov]? [~akalashnikov]?) would like to pick up this work, and re-implement [~akalashnikov]'s fix for 1.14 I would be happy to review it. > Negative time in throughput calculator > -------------------------------------- > > Key: FLINK-25454 > URL: https://issues.apache.org/jira/browse/FLINK-25454 > Project: Flink > Issue Type: Bug > Components: Runtime / Network > Affects Versions: 1.15.0 > Reporter: Anton Kalashnikov > Assignee: Anton Kalashnikov > Priority: Major > Labels: pull-request-available > Fix For: 1.15.0 > > > Found during the random test: > {noformat} > 2021-12-23 11:52:01,645 WARN org.apache.flink.runtime.taskmanager.Task > [] - KeyedProcess -> Sink: Unnamed (3/3)#0 > (1321490f33c6370f2d68c413a8a0b0c1) switched from RUNNING to FAILED with > failure cause: java.lang.IllegalArgumentException: Time should be non negative > at > org.apache.flink.util.Preconditions.checkArgument(Preconditions.java:138) > at > org.apache.flink.runtime.throughput.ThroughputCalculator.calculateThroughput(ThroughputCalculator.java:90) > at > org.apache.flink.runtime.throughput.ThroughputCalculator.calculateThroughput(ThroughputCalculator.java:81) > at > org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.triggerDebloating(SingleInputGate.java:414) > at > org.apache.flink.runtime.taskmanager.InputGateWithMetrics.triggerDebloating(InputGateWithMetrics.java:90) > at > org.apache.flink.streaming.runtime.tasks.StreamTask.debloat(StreamTask.java:786) > at > org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$scheduleBufferDebloater$3(StreamTask.java:777) > at > org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.runThrowing(StreamTaskActionExecutor.java:50) > at > org.apache.flink.streaming.runtime.tasks.mailbox.Mail.run(Mail.java:90) > at > org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMailsWhenDefaultActionUnavailable(MailboxProcessor.java:338) > at > org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMail(MailboxProcessor.java:324) > at > org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:201) > at > org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:801) > at > org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:750) > at > org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:948) > at > org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:927) > at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:741) > at org.apache.flink.runtime.taskmanager.Task.run(Task.java:563) > at java.base/java.lang.Thread.run(Unknown Source) > {noformat} -- This message was sent by Atlassian Jira (v8.20.7#820007)