[
https://issues.apache.org/jira/browse/FLINK-36252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-36252:
-------------------------------
Description:
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=61813&view=logs&j=77a9d8e1-d610-59b3-fc2a-4766541e0e33&t=125e07e7-8de0-5c6c-a541-a567415af3ef&l=10349
{code:java}
Sep 02 04:42:38 04:42:38.309 [ERROR]
org.apache.flink.streaming.api.operators.async.AsyncWaitOperatorTest.testProcessingTimeUnorderedWithRetry
-- Time elapsed: 0.336 s <<< ERROR!
Sep 02 04:42:38 java.util.concurrent.RejectedExecutionException:
org.apache.flink.streaming.runtime.tasks.mailbox.TaskMailbox$MailboxClosedException:
Mailbox is in state QUIESCED, but is required to be in state OPEN for put
operations.
Sep 02 04:42:38 at
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxExecutorImpl.execute(MailboxExecutorImpl.java:84)
Sep 02 04:42:38 at
org.apache.flink.api.common.operators.MailboxExecutor.execute(MailboxExecutor.java:165)
Sep 02 04:42:38 at
org.apache.flink.streaming.api.operators.async.AsyncWaitOperator$ResultHandler.processInMailbox(AsyncWaitOperator.java:601)
Sep 02 04:42:38 at
org.apache.flink.streaming.api.operators.async.AsyncWaitOperator$ResultHandler.complete(AsyncWaitOperator.java:596)
Sep 02 04:42:38 at
org.apache.flink.streaming.api.operators.async.AsyncWaitOperator$RetryableResultHandlerDelegator.processRetry(AsyncWaitOperator.java:548)
Sep 02 04:42:38 at
org.apache.flink.streaming.api.operators.async.AsyncWaitOperator$RetryableResultHandlerDelegator.lambda$processRetryInMailBox$1(AsyncWaitOperator.java:509)
Sep 02 04:42:38 at
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.runThrowing(StreamTaskActionExecutor.java:50)
Sep 02 04:42:38 at
org.apache.flink.streaming.runtime.tasks.mailbox.Mail.run(Mail.java:101)
Sep 02 04:42:38 at
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMail(MailboxProcessor.java:414)
Sep 02 04:42:38 at
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.drain(MailboxProcessor.java:205)
Sep 02 04:42:38 at
org.apache.flink.streaming.runtime.tasks.StreamTask.afterInvoke(StreamTask.java:1018)
Sep 02 04:42:38 at
org.apache.flink.streaming.runtime.tasks.StreamTaskMailboxTestHarness.finishProcessing(StreamTaskMailboxTestHarness.java:166)
Sep 02 04:42:38 at
org.apache.flink.streaming.runtime.tasks.StreamTaskMailboxTestHarness.close(StreamTaskMailboxTestHarness.java:178)
Sep 02 04:42:38 at
org.apache.flink.streaming.api.operators.async.AsyncWaitOperatorTest.testProcessingTimeWithRetry(AsyncWaitOperatorTest.java:1249)
Sep 02 04:42:38 at
org.apache.flink.streaming.api.operators.async.AsyncWaitOperatorTest.testProcessingTimeUnorderedWithRetry(AsyncWaitOperatorTest.java:1175)
Sep 02 04:42:38 at java.lang.reflect.Method.invoke(Method.java:498)
Sep 02 04:42:38 at
java.util.concurrent.RecursiveAction.exec(RecursiveAction.java:189)
Sep 02 04:42:38 at
java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
Sep 02 04:42:38 at
java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
Sep 02 04:42:38 at
java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
Sep 02 04:42:38 at
java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
Sep 02 04:42:38 Caused by:
org.apache.flink.streaming.runtime.tasks.mailbox.TaskMailbox$MailboxClosedException:
Mailbox is in state QUIESCED, but is required to be in state OPEN for put
operations.
Sep 02 04:42:38 at
org.apache.flink.streaming.runtime.tasks.mailbox.TaskMailboxImpl.checkPutStateConditions(TaskMailboxImpl.java:269)
Sep 02 04:42:38 at
org.apache.flink.streaming.runtime.tasks.mailbox.TaskMailboxImpl.put(TaskMailboxImpl.java:197)
Sep 02 04:42:38 at
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxExecutorImpl.execute(MailboxExecutorImpl.java:75)
Sep 02 04:42:38 ... 20 more
{code}
> AsyncWaitOperatorTest.testProcessingTimeUnorderedWithRetry failed on AZP
> ------------------------------------------------------------------------
>
> Key: FLINK-36252
> URL: https://issues.apache.org/jira/browse/FLINK-36252
> Project: Flink
> Issue Type: Bug
> Components: Build System / CI
> Affects Versions: 2.0.0
> Reporter: Weijie Guo
> Priority: Major
>
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=61813&view=logs&j=77a9d8e1-d610-59b3-fc2a-4766541e0e33&t=125e07e7-8de0-5c6c-a541-a567415af3ef&l=10349
> {code:java}
> Sep 02 04:42:38 04:42:38.309 [ERROR]
> org.apache.flink.streaming.api.operators.async.AsyncWaitOperatorTest.testProcessingTimeUnorderedWithRetry
> -- Time elapsed: 0.336 s <<< ERROR!
> Sep 02 04:42:38 java.util.concurrent.RejectedExecutionException:
> org.apache.flink.streaming.runtime.tasks.mailbox.TaskMailbox$MailboxClosedException:
> Mailbox is in state QUIESCED, but is required to be in state OPEN for put
> operations.
> Sep 02 04:42:38 at
> org.apache.flink.streaming.runtime.tasks.mailbox.MailboxExecutorImpl.execute(MailboxExecutorImpl.java:84)
> Sep 02 04:42:38 at
> org.apache.flink.api.common.operators.MailboxExecutor.execute(MailboxExecutor.java:165)
> Sep 02 04:42:38 at
> org.apache.flink.streaming.api.operators.async.AsyncWaitOperator$ResultHandler.processInMailbox(AsyncWaitOperator.java:601)
> Sep 02 04:42:38 at
> org.apache.flink.streaming.api.operators.async.AsyncWaitOperator$ResultHandler.complete(AsyncWaitOperator.java:596)
> Sep 02 04:42:38 at
> org.apache.flink.streaming.api.operators.async.AsyncWaitOperator$RetryableResultHandlerDelegator.processRetry(AsyncWaitOperator.java:548)
> Sep 02 04:42:38 at
> org.apache.flink.streaming.api.operators.async.AsyncWaitOperator$RetryableResultHandlerDelegator.lambda$processRetryInMailBox$1(AsyncWaitOperator.java:509)
> Sep 02 04:42:38 at
> org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.runThrowing(StreamTaskActionExecutor.java:50)
> Sep 02 04:42:38 at
> org.apache.flink.streaming.runtime.tasks.mailbox.Mail.run(Mail.java:101)
> Sep 02 04:42:38 at
> org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMail(MailboxProcessor.java:414)
> Sep 02 04:42:38 at
> org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.drain(MailboxProcessor.java:205)
> Sep 02 04:42:38 at
> org.apache.flink.streaming.runtime.tasks.StreamTask.afterInvoke(StreamTask.java:1018)
> Sep 02 04:42:38 at
> org.apache.flink.streaming.runtime.tasks.StreamTaskMailboxTestHarness.finishProcessing(StreamTaskMailboxTestHarness.java:166)
> Sep 02 04:42:38 at
> org.apache.flink.streaming.runtime.tasks.StreamTaskMailboxTestHarness.close(StreamTaskMailboxTestHarness.java:178)
> Sep 02 04:42:38 at
> org.apache.flink.streaming.api.operators.async.AsyncWaitOperatorTest.testProcessingTimeWithRetry(AsyncWaitOperatorTest.java:1249)
> Sep 02 04:42:38 at
> org.apache.flink.streaming.api.operators.async.AsyncWaitOperatorTest.testProcessingTimeUnorderedWithRetry(AsyncWaitOperatorTest.java:1175)
> Sep 02 04:42:38 at java.lang.reflect.Method.invoke(Method.java:498)
> Sep 02 04:42:38 at
> java.util.concurrent.RecursiveAction.exec(RecursiveAction.java:189)
> Sep 02 04:42:38 at
> java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
> Sep 02 04:42:38 at
> java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
> Sep 02 04:42:38 at
> java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
> Sep 02 04:42:38 at
> java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
> Sep 02 04:42:38 Caused by:
> org.apache.flink.streaming.runtime.tasks.mailbox.TaskMailbox$MailboxClosedException:
> Mailbox is in state QUIESCED, but is required to be in state OPEN for put
> operations.
> Sep 02 04:42:38 at
> org.apache.flink.streaming.runtime.tasks.mailbox.TaskMailboxImpl.checkPutStateConditions(TaskMailboxImpl.java:269)
> Sep 02 04:42:38 at
> org.apache.flink.streaming.runtime.tasks.mailbox.TaskMailboxImpl.put(TaskMailboxImpl.java:197)
> Sep 02 04:42:38 at
> org.apache.flink.streaming.runtime.tasks.mailbox.MailboxExecutorImpl.execute(MailboxExecutorImpl.java:75)
> Sep 02 04:42:38 ... 20 more
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
