Jim Hughes created FLINK-33918:
----------------------------------
Summary: 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
>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]
```
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)
```
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
