[ https://issues.apache.org/jira/browse/FLINK-33918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17799149#comment-17799149 ]
Jim Hughes commented on FLINK-33918: ------------------------------------ Sorry for the duplicate! > 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)