Huang Xingbo created FLINK-27674:
------------------------------------
Summary: Elasticsearch6SinkE2ECase test hangs
Key: FLINK-27674
URL: https://issues.apache.org/jira/browse/FLINK-27674
Project: Flink
Issue Type: Bug
Components: Connectors / ElasticSearch
Affects Versions: 1.16.0
Reporter: Huang Xingbo
{code:java}
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)
{code}
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
--
This message was sent by Atlassian Jira
(v8.20.7#820007)
