[
https://issues.apache.org/jira/browse/FLINK-32335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reassigned FLINK-32335:
--------------------------------
Assignee: Jiang Xin
> 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
> Assignee: Jiang Xin
> Priority: Major
> Labels: pull-request-available
> Fix For: ml-2.4.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)
