You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Jiang Xin (Jira)" <ji...@apache.org> on 2023/06/14 08:49:00 UTC
[jira] [Created] (FLINK-32335) Fix the Flink ML unittest failure
Jiang Xin created FLINK-32335:
---------------------------------
Summary: Fix the Flink ML unittest failure
Key: FLINK-32335
URL: https://issues.apache.org/jira/browse/FLINK-32335
Project: Flink
Issue Type: New Feature
Components: Library / Machine Learning
Reporter: Jiang Xin
Fix For: ml-2.3.0
The [github CI](https://github.com/apache/flink-ml/actions/runs/5227269169/jobs/9438737620) of Flink ML failed because of the following exception.
{code:java}
E Caused by: java.util.ConcurrentModificationException
223E at java.util.ArrayDeque$DeqIterator.next(ArrayDeque.java:648)
224E at java.util.Collections$UnmodifiableCollection$1.next(Collections.java:1044)
225E at org.apache.flink.iteration.operator.HeadOperator.parseInputChannelEvents(HeadOperator.java:464)
226E at org.apache.flink.iteration.operator.HeadOperator.endInput(HeadOperator.java:392)
227E at org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.endOperatorInput(StreamOperatorWrapper.java:96)
228E at org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.endInput(RegularOperatorChain.java:97)
229E at org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:68)
230E at org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:550)
231E at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:231)
232E at org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:839)
233E at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:788)
234E at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:952)
235E at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:931)
236E at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:745)
237E at org.apache.flink.runtime.taskmanager.Task.run(Task.java:562)
238E at java.lang.Thread.run(Thread.java:750){code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)