[
https://issues.apache.org/jira/browse/FLINK-33918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17799147#comment-17799147
]
Martijn Visser commented on FLINK-33918:
----------------------------------------
[~jhughes] I think you might have to rebase, it appears to have been fixed via
FLINK-31472
> Fix AsyncSinkWriterThrottlingTest test failure
> ----------------------------------------------
>
> Key: FLINK-33918
> URL: https://issues.apache.org/jira/browse/FLINK-33918
> Project: Flink
> Issue Type: Bug
> Affects Versions: 1.19.0
> Reporter: Jim Hughes
> Priority: Major
> Labels: test-stability
>
> From
> [https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=55700&view=logs&j=1c002d28-a73d-5309-26ee-10036d8476b4&t=d1c117a6-8f13-5466-55f0-d48dbb767fcd]
> {code:java}
> Dec 20 03:09:03 03:09:03.411 [ERROR]
> org.apache.flink.connector.base.sink.writer.AsyncSinkWriterThrottlingTest.testSinkThroughputShouldThrottleToHalfBatchSize
> – Time elapsed: 0.879 s <<< ERROR!
> Dec 20 03:09:03 java.lang.IllegalStateException: Illegal thread detected.
> This method must be called from inside the mailbox thread!
> Dec 20 03:09:03 at
> org.apache.flink.streaming.runtime.tasks.mailbox.TaskMailboxImpl.checkIsMailboxThread(TaskMailboxImpl.java:262)
>
> Dec 20 03:09:03 at
> org.apache.flink.streaming.runtime.tasks.mailbox.TaskMailboxImpl.take(TaskMailboxImpl.java:137)
>
> Dec 20 03:09:03 at
> org.apache.flink.streaming.runtime.tasks.mailbox.MailboxExecutorImpl.yield(MailboxExecutorImpl.java:84)
>
> Dec 20 03:09:03 at
> org.apache.flink.connector.base.sink.writer.AsyncSinkWriter.flush(AsyncSinkWriter.java:367)
>
> Dec 20 03:09:03 at
> org.apache.flink.connector.base.sink.writer.AsyncSinkWriter.lambda$registerCallback$3(AsyncSinkWriter.java:315)
>
> Dec 20 03:09:03 at
> org.apache.flink.streaming.runtime.tasks.TestProcessingTimeService$CallbackTask.onProcessingTime(TestProcessingTimeService.java:199)
>
> Dec 20 03:09:03 at
> org.apache.flink.streaming.runtime.tasks.TestProcessingTimeService.setCurrentTime(TestProcessingTimeService.java:76)
>
> Dec 20 03:09:03 at
> org.apache.flink.connector.base.sink.writer.AsyncSinkWriterThrottlingTest.testSinkThroughputShouldThrottleToHalfBatchSize(AsyncSinkWriterThrottlingTest.java:64)
>
> Dec 20 03:09:03 at java.lang.reflect.Method.invoke(Method.java:498) {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
