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)
