[FLINK-27674] Elasticsearch6SinkE2ECase test hangs

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Done
• Affects Version/s: 1.16.0
• Component/s: Connectors / ElasticSearch
• Labels: test-stability
• Assignee: Unassigned
• Reporter: Huang Xingbo
• Created: 18/May/22 02:05
• Updated: 20/May/22 08:52
• Resolved: 20/May/22 08:52

Description

2022-05-17T14:23:20.2220667Z May 17 14:23:20 [INFO] Running org.apache.flink.streaming.tests.Elasticsearch6SinkE2ECase
2022-05-17T16:46:42.2757438Z ==========================================================================================
2022-05-17T16:46:42.2769104Z === WARNING: This task took already 95% of the available time budget of 284 minutes ===
2022-05-17T16:46:42.2769752Z ==========================================================================================
2022-05-17T16:46:42.2777415Z ==============================================================================
2022-05-17T16:46:42.2778082Z The following Java processes are running (JPS)
2022-05-17T16:46:42.2778711Z ==============================================================================
2022-05-17T16:46:42.4370838Z 366642 surefirebooter7296810110127514313.jar
2022-05-17T16:46:42.4371962Z 323278 Launcher
2022-05-17T16:46:42.4378950Z 384312 Jps
2022-05-17T16:46:42.4452836Z ==============================================================================
2022-05-17T16:46:42.4453843Z Printing stack trace of Java process 366642
2022-05-17T16:46:42.4454796Z ==============================================================================
2022-05-17T16:46:42.9967200Z 2022-05-17 16:46:42
2022-05-17T16:46:42.9968158Z Full thread dump OpenJDK 64-Bit Server VM (25.332-b09 mixed mode):
2022-05-17T16:46:42.9968402Z 
2022-05-17T16:46:42.9968953Z "Attach Listener" #6017 daemon prio=9 os_prio=0 tid=0x00007f4cf0007000 nid=0x5dd53 waiting on condition [0x0000000000000000]
2022-05-17T16:46:42.9969533Z    java.lang.Thread.State: RUNNABLE
2022-05-17T16:46:42.9969714Z 
2022-05-17T16:46:42.9970494Z "ForkJoinPool-1-worker-0" #6011 daemon prio=5 os_prio=0 tid=0x00007f4b4ed92800 nid=0x5cfea waiting on condition [0x00007f4b35b9b000]
2022-05-17T16:46:42.9971118Z    java.lang.Thread.State: TIMED_WAITING (parking)
2022-05-17T16:46:42.9971752Z 	at sun.misc.Unsafe.park(Native Method)
2022-05-17T16:46:42.9972494Z 	- parking to wait for  <0x00000000939d6cd0> (a java.util.concurrent.ForkJoinPool)
2022-05-17T16:46:42.9973134Z 	at java.util.concurrent.ForkJoinPool.awaitWork(ForkJoinPool.java:1824)
2022-05-17T16:46:42.9973801Z 	at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1693)
2022-05-17T16:46:43.0113835Z 	at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
2022-05-17T16:46:43.0114433Z 
2022-05-17T16:46:43.0118656Z "flink-rest-client-netty-thread-1" #6006 daemon prio=5 os_prio=0 tid=0x00007f4b4ed8f000 nid=0x5bb03 runnable [0x00007f4b34181000]
2022-05-17T16:46:43.0119406Z    java.lang.Thread.State: RUNNABLE
2022-05-17T16:46:43.0120063Z 	at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method)
2022-05-17T16:46:43.0120921Z 	at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269)
2022-05-17T16:46:43.0121666Z 	at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93)
2022-05-17T16:46:43.0122507Z 	at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86)
2022-05-17T16:46:43.0123735Z 	- locked <0x00000000e4e90c80> (a org.apache.flink.shaded.netty4.io.netty.channel.nio.SelectedSelectionKeySet)
2022-05-17T16:46:43.0124873Z 	- locked <0x00000000e4e90a90> (a java.util.Collections$UnmodifiableSet)
2022-05-17T16:46:43.0125863Z 	- locked <0x00000000e4e909b8> (a sun.nio.ch.EPollSelectorImpl)
2022-05-17T16:46:43.0126648Z 	at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97)
2022-05-17T16:46:43.0127370Z 	at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:101)
2022-05-17T16:46:43.0128211Z 	at org.apache.flink.shaded.netty4.io.netty.channel.nio.SelectedSelectionKeySetSelector.select(SelectedSelectionKeySetSelector.java:68)
2022-05-17T16:46:43.0129260Z 	at org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.select(NioEventLoop.java:810)
2022-05-17T16:46:43.0130119Z 	at org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:457)
2022-05-17T16:46:43.0131134Z 	at org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:986)
2022-05-17T16:46:43.0137869Z 	at org.apache.flink.shaded.netty4.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
2022-05-17T16:46:43.0138683Z 	at java.lang.Thread.run(Thread.java:750)

https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=35749&view=logs&j=af184cdd-c6d8-5084-0b69-7e9c67b35f7a&t=160c9ae5-96fd-516e-1c91-deb81f59292a