[ 
https://issues.apache.org/jira/browse/FLINK-19448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225505#comment-17225505
 ] 

Kezhu Wang commented on FLINK-19448:
------------------------------------

I think I may find the cause.

First, let's see what javadoc say about {{size()}} and {{isEmpty()}}:
{quote}Bear in mind that the results of aggregate status methods including 
size, isEmpty, and containsValue are typically useful only when a map is not 
undergoing concurrent updates in other threads. Otherwise the results of these 
methods reflect transient states that may be adequate for monitoring or 
estimation purposes, but not for program control.
{quote}
Second, let's see simplified source code of {{ConcurrentHashMap.remove}} and 
its complementary method {{ConcurrentHashMap.replaceNode}}:
{code:java}
```java
    public V remove(Object key) {
        return replaceNode(key, null, null);
    }

    /**
     * Implementation for the four public remove/replace methods:
     * Replaces node value with v, conditional upon match of cv if
     * non-null.  If resulting value is null, delete.
     */
    final V replaceNode(Object key, V value, Object cv) {
        int hash = spread(key.hashCode());
        for (Node<K,V>[] tab = table;;) {
            Node<K,V> f; int n, i, fh;
            if (tab == null || (n = tab.length) == 0 ||
                (f = tabAt(tab, i = (n - 1) & hash)) == null)
                break;                         // tag(absent)
            else if ((fh = f.hash) == MOVED)
                tab = helpTransfer(tab, f);
            else {
                V oldVal = null;
                boolean validated = false;
                synchronized (f) {      // tag(removing)
                    if (tabAt(tab, i) == f) {
                        // ... replacing code omitted here
                    }
                }
                if (validated) {        // tag(size-counting-synchronization)
                    if (oldVal != null) {
                        if (value == null)
                            addCount(-1L, -1);
                        return oldVal;
                    }
                    break;
                }
            }
        }
        return null;
    }
```
{code}

There is no synchronization around key-removing and size-counting. Seems that 
key-removing happens-before size-counting in concurrent sense.

Finally, I have published two online repls to demonstrate this for 
[openjdk8|https://repl.it/@kezhuw/openjdk8-concurrent-hashmap-unsynchronized-size]
 and 
[openjdk11|https://repl.it/@kezhuw/openjdk11-concurrent-hashmap-unsynchronized-size].
 Both will fail after a number of runs which may exceed one thousand in extreme 
cases.

I am kind of straggling about whether this is a bug or concurrent nature of 
{{ConcurrentHashMap}}. I think it is normal to not rely on {{size}} to detect 
concurrent key removing. But after {{ConcurrentHashMap.remove}}, sequential 
{{ConcurrentHashMap.size()}} or {{ConcurrentHashMap.isEmpty()}} should reflect 
that removing, otherwise it is somewhat counterintuitive from my perspective. I 
will report this to OpenJDK in next few days if no further inspiration.

Back to Flink side, in {{SplitFetcherManager.maybeShutdownFinishedFetchers}} 
idle-fetcher-removing runs concurrently with {{SplitFetcher.shutdownHook}}. 
{{fetchers.isEmpty()}} may return {{false}} even if last entry removed. This 
will make {{SourceReaderBase.finishedOrAvailableLater}} erroneously returns 
{{InputStatus.NOTHING_AVAILABLE}} instead of {{InputStatus.END_OF_INPUT}}.

> CoordinatedSourceITCase.testEnumeratorReaderCommunication hangs
> ---------------------------------------------------------------
>
>                 Key: FLINK-19448
>                 URL: https://issues.apache.org/jira/browse/FLINK-19448
>             Project: Flink
>          Issue Type: Bug
>          Components: Connectors / Common, Tests
>    Affects Versions: 1.12.0
>            Reporter: Dian Fu
>            Priority: Major
>              Labels: test-stability
>
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=7042&view=logs&j=5cae8624-c7eb-5c51-92d3-4d2dacedd221&t=420bd9ec-164e-562e-8947-0dacde3cec91
> {code}
> 2020-09-28T21:40:41.0736918Z [INFO] Running 
> org.apache.flink.connector.base.source.reader.CoordinatedSourceITCase
> 2020-09-28T21:57:23.4590733Z 
> ==============================================================================
> 2020-09-28T21:57:23.4591238Z Process produced no output for 900 seconds.
> 2020-09-28T21:57:23.4591593Z 
> ==============================================================================
> 2020-09-28T21:57:23.4595995Z 
> ==============================================================================
> 2020-09-28T21:57:23.4596439Z The following Java processes are running (JPS)
> 2020-09-28T21:57:23.4596789Z 
> ==============================================================================
> 2020-09-28T21:57:23.4638075Z Picked up JAVA_TOOL_OPTIONS: 
> -XX:+HeapDumpOnOutOfMemoryError
> 2020-09-28T21:57:23.6127853Z 21907 surefirebooter2023202237772619676.jar
> 2020-09-28T21:57:23.6128185Z 534 Launcher
> 2020-09-28T21:57:23.6128381Z 24630 Jps
> 2020-09-28T21:57:23.6159852Z 
> ==============================================================================
> 2020-09-28T21:57:23.6160256Z Printing stack trace of Java process 21907
> 2020-09-28T21:57:23.6160806Z 
> ==============================================================================
> 2020-09-28T21:57:23.6203860Z Picked up JAVA_TOOL_OPTIONS: 
> -XX:+HeapDumpOnOutOfMemoryError
> 2020-09-28T21:57:23.9470219Z 2020-09-28 21:57:23
> 2020-09-28T21:57:23.9471512Z Full thread dump OpenJDK 64-Bit Server VM 
> (25.242-b08 mixed mode):
> 2020-09-28T21:57:23.9472274Z 
> 2020-09-28T21:57:23.9472805Z "Attach Listener" #215 daemon prio=9 os_prio=0 
> tid=0x00007f13c8074800 nid=0x6052 waiting on condition [0x0000000000000000]
> 2020-09-28T21:57:23.9473343Z    java.lang.Thread.State: RUNNABLE
> 2020-09-28T21:57:23.9473660Z 
> 2020-09-28T21:57:23.9474554Z "flink-akka.actor.default-dispatcher-103" #214 
> prio=5 os_prio=0 tid=0x00007f13cc1b5000 nid=0x6018 waiting on condition 
> [0x00007f13bb4f5000]
> 2020-09-28T21:57:23.9475189Z    java.lang.Thread.State: WAITING (parking)
> 2020-09-28T21:57:23.9475815Z  at sun.misc.Unsafe.park(Native Method)
> 2020-09-28T21:57:23.9476662Z  - parking to wait for  <0x0000000087a80408> (a 
> akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinPool)
> 2020-09-28T21:57:23.9477295Z  at 
> akka.dispatch.forkjoin.ForkJoinPool.scan(ForkJoinPool.java:2075)
> 2020-09-28T21:57:23.9477871Z  at 
> akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
> 2020-09-28T21:57:23.9480210Z  at 
> akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
> 2020-09-28T21:57:23.9480723Z 
> 2020-09-28T21:57:23.9481669Z "flink-taskexecutor-io-thread-8" #125 daemon 
> prio=5 os_prio=0 tid=0x00007f13e401d000 nid=0x571b waiting on condition 
> [0x00007f13e84f8000]
> 2020-09-28T21:57:23.9482321Z    java.lang.Thread.State: WAITING (parking)
> 2020-09-28T21:57:23.9482727Z  at sun.misc.Unsafe.park(Native Method)
> 2020-09-28T21:57:23.9483562Z  - parking to wait for  <0x0000000087a80860> (a 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
> 2020-09-28T21:57:23.9484241Z  at 
> java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> 2020-09-28T21:57:23.9484899Z  at 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
> 2020-09-28T21:57:23.9485585Z  at 
> java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
> 2020-09-28T21:57:23.9486194Z  at 
> java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)
> 2020-09-28T21:57:23.9486818Z  at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)
> 2020-09-28T21:57:23.9487440Z  at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2020-09-28T21:57:23.9487970Z  at java.lang.Thread.run(Thread.java:748)
> 2020-09-28T21:57:23.9488278Z 
> 2020-09-28T21:57:23.9489120Z "flink-taskexecutor-io-thread-7" #124 daemon 
> prio=5 os_prio=0 tid=0x00007f13e401c800 nid=0x571a waiting on condition 
> [0x00007f13b8f46000]
> 2020-09-28T21:57:23.9489760Z    java.lang.Thread.State: WAITING (parking)
> 2020-09-28T21:57:23.9490190Z  at sun.misc.Unsafe.park(Native Method)
> 2020-09-28T21:57:23.9491003Z  - parking to wait for  <0x0000000087a80860> (a 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
> 2020-09-28T21:57:23.9491667Z  at 
> java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> 2020-09-28T21:57:23.9492821Z  at 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
> 2020-09-28T21:57:23.9493524Z  at 
> java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
> 2020-09-28T21:57:23.9494139Z  at 
> java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)
> 2020-09-28T21:57:23.9494754Z  at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)
> 2020-09-28T21:57:23.9496451Z  at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2020-09-28T21:57:23.9496992Z  at java.lang.Thread.run(Thread.java:748)
> 2020-09-28T21:57:23.9497201Z 
> 2020-09-28T21:57:23.9498016Z "flink-taskexecutor-io-thread-6" #123 daemon 
> prio=5 os_prio=0 tid=0x00007f13e4019000 nid=0x5719 waiting on condition 
> [0x00007f13e82f6000]
> 2020-09-28T21:57:23.9498481Z    java.lang.Thread.State: WAITING (parking)
> 2020-09-28T21:57:23.9498788Z  at sun.misc.Unsafe.park(Native Method)
> 2020-09-28T21:57:23.9500245Z  - parking to wait for  <0x0000000087a80860> (a 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
> 2020-09-28T21:57:23.9500756Z  at 
> java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> 2020-09-28T21:57:23.9501473Z  at 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
> 2020-09-28T21:57:23.9502044Z  at 
> java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
> 2020-09-28T21:57:23.9502519Z  at 
> java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)
> 2020-09-28T21:57:23.9503017Z  at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)
> 2020-09-28T21:57:23.9503595Z  at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2020-09-28T21:57:23.9503995Z  at java.lang.Thread.run(Thread.java:748)
> 2020-09-28T21:57:23.9504209Z 
> 2020-09-28T21:57:23.9504942Z "Flink-DispatcherRestEndpoint-thread-4" #113 
> daemon prio=5 os_prio=0 tid=0x00007f13f801c800 nid=0x5637 waiting on 
> condition [0x00007f13e88fa000]
> 2020-09-28T21:57:23.9505431Z    java.lang.Thread.State: WAITING (parking)
> 2020-09-28T21:57:23.9505743Z  at sun.misc.Unsafe.park(Native Method)
> 2020-09-28T21:57:23.9506407Z  - parking to wait for  <0x0000000087a80e70> (a 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
> 2020-09-28T21:57:23.9506909Z  at 
> java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> 2020-09-28T21:57:23.9507460Z  at 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
> 2020-09-28T21:57:23.9508086Z  at 
> java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088)
> 2020-09-28T21:57:23.9508870Z  at 
> java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)
> 2020-09-28T21:57:23.9509439Z  at 
> java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)
> 2020-09-28T21:57:23.9509922Z  at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)
> 2020-09-28T21:57:23.9513273Z  at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2020-09-28T21:57:23.9513750Z  at java.lang.Thread.run(Thread.java:748)
> 2020-09-28T21:57:23.9513951Z 
> 2020-09-28T21:57:23.9514797Z "Flink-DispatcherRestEndpoint-thread-3" #112 
> daemon prio=5 os_prio=0 tid=0x00007f13dc09c800 nid=0x562c waiting on 
> condition [0x00007f13babf0000]
> 2020-09-28T21:57:23.9515275Z    java.lang.Thread.State: WAITING (parking)
> 2020-09-28T21:57:23.9515582Z  at sun.misc.Unsafe.park(Native Method)
> 2020-09-28T21:57:23.9517202Z  - parking to wait for  <0x0000000087a80e70> (a 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
> 2020-09-28T21:57:23.9518111Z  at 
> java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> 2020-09-28T21:57:23.9518674Z  at 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
> 2020-09-28T21:57:23.9519312Z  at 
> java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088)
> 2020-09-28T21:57:23.9519922Z  at 
> java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)
> 2020-09-28T21:57:23.9520489Z  at 
> java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)
> 2020-09-28T21:57:23.9520990Z  at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)
> 2020-09-28T21:57:23.9521478Z  at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2020-09-28T21:57:23.9521891Z  at java.lang.Thread.run(Thread.java:748)
> 2020-09-28T21:57:23.9522095Z 
> 2020-09-28T21:57:23.9522967Z "Flink-DispatcherRestEndpoint-thread-2" #110 
> daemon prio=5 os_prio=0 tid=0x00007f13dc024000 nid=0x561e waiting on 
> condition [0x00007f13e87f9000]
> 2020-09-28T21:57:23.9523467Z    java.lang.Thread.State: WAITING (parking)
> 2020-09-28T21:57:23.9523759Z  at sun.misc.Unsafe.park(Native Method)
> 2020-09-28T21:57:23.9524463Z  - parking to wait for  <0x0000000087a80e70> (a 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
> 2020-09-28T21:57:23.9525134Z  at 
> java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> 2020-09-28T21:57:23.9525671Z  at 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
> 2020-09-28T21:57:23.9526313Z  at 
> java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088)
> 2020-09-28T21:57:23.9526940Z  at 
> java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)
> 2020-09-28T21:57:23.9527561Z  at 
> java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)
> 2020-09-28T21:57:23.9528066Z  at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)
> 2020-09-28T21:57:23.9528570Z  at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2020-09-28T21:57:23.9528969Z  at java.lang.Thread.run(Thread.java:748)
> 2020-09-28T21:57:23.9529182Z 
> 2020-09-28T21:57:23.9529954Z "SourceCoordinator-Source: TestingSource -> 
> Sink: Unnamed" #107 prio=5 os_prio=0 tid=0x00007f13dc0a9000 nid=0x5611 
> waiting on condition [0x00007f13ba156000]
> 2020-09-28T21:57:23.9530505Z    java.lang.Thread.State: WAITING (parking)
> 2020-09-28T21:57:23.9530819Z  at sun.misc.Unsafe.park(Native Method)
> 2020-09-28T21:57:23.9531489Z  - parking to wait for  <0x0000000087a81460> (a 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
> 2020-09-28T21:57:23.9532000Z  at 
> java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> 2020-09-28T21:57:23.9532555Z  at 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
> 2020-09-28T21:57:23.9533109Z  at 
> java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
> 2020-09-28T21:57:23.9533600Z  at 
> java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)
> 2020-09-28T21:57:23.9534100Z  at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)
> 2020-09-28T21:57:23.9534591Z  at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2020-09-28T21:57:23.9535012Z  at java.lang.Thread.run(Thread.java:748)
> 2020-09-28T21:57:23.9535207Z 
> 2020-09-28T21:57:23.9535569Z "CloseableReaperThread" #105 daemon prio=5 
> os_prio=0 tid=0x00007f13d0024800 nid=0x560f in Object.wait() 
> [0x00007f13ba257000]
> 2020-09-28T21:57:23.9536032Z    java.lang.Thread.State: WAITING (on object 
> monitor)
> 2020-09-28T21:57:23.9536342Z  at java.lang.Object.wait(Native Method)
> 2020-09-28T21:57:23.9536920Z  - waiting on <0x0000000087a816e8> (a 
> java.lang.ref.ReferenceQueue$Lock)
> 2020-09-28T21:57:23.9537348Z  at 
> java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:144)
> 2020-09-28T21:57:23.9537954Z  - locked <0x0000000087a816e8> (a 
> java.lang.ref.ReferenceQueue$Lock)
> 2020-09-28T21:57:23.9538370Z  at 
> java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:165)
> 2020-09-28T21:57:23.9539931Z  at 
> org.apache.flink.core.fs.SafetyNetCloseableRegistry$CloseableReaperThread.run(SafetyNetCloseableRegistry.java:209)
> 2020-09-28T21:57:23.9540324Z 
> 2020-09-28T21:57:23.9541134Z "Source: TestingSource -> Sink: Unnamed (2/4)" 
> #103 prio=5 os_prio=0 tid=0x00007f13d81db000 nid=0x560d waiting on condition 
> [0x00007f13b8e45000]
> 2020-09-28T21:57:23.9542119Z    java.lang.Thread.State: WAITING (parking)
> 2020-09-28T21:57:23.9545357Z  at sun.misc.Unsafe.park(Native Method)
> 2020-09-28T21:57:23.9547428Z  - parking to wait for  <0x0000000087a81890> (a 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
> 2020-09-28T21:57:23.9547946Z  at 
> java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> 2020-09-28T21:57:23.9548949Z  at 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
> 2020-09-28T21:57:23.9550987Z  at 
> org.apache.flink.streaming.runtime.tasks.mailbox.TaskMailboxImpl.take(TaskMailboxImpl.java:146)
> 2020-09-28T21:57:23.9551574Z  at 
> org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMail(MailboxProcessor.java:298)
> 2020-09-28T21:57:23.9552333Z  at 
> org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:183)
> 2020-09-28T21:57:23.9552915Z  at 
> org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:594)
> 2020-09-28T21:57:23.9556038Z  at 
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:558)
> 2020-09-28T21:57:23.9556541Z  at 
> org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:722)
> 2020-09-28T21:57:23.9556973Z  at 
> org.apache.flink.runtime.taskmanager.Task.run(Task.java:547)
> 2020-09-28T21:57:23.9557477Z  at java.lang.Thread.run(Thread.java:748)
> 2020-09-28T21:57:23.9557695Z 
> 2020-09-28T21:57:23.9561877Z 
> "AkkaRpcService-Supervisor-Termination-Future-Executor-thread-1" #97 daemon 
> prio=5 os_prio=0 tid=0x00007f13e00dc000 nid=0x5607 waiting on condition 
> [0x00007f13b944b000]
> 2020-09-28T21:57:23.9562627Z    java.lang.Thread.State: WAITING (parking)
> 2020-09-28T21:57:23.9565093Z  at sun.misc.Unsafe.park(Native Method)
> 2020-09-28T21:57:23.9570829Z  - parking to wait for  <0x0000000087a81d20> (a 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
> 2020-09-28T21:57:23.9575651Z  at 
> java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> 2020-09-28T21:57:23.9576427Z  at 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
> 2020-09-28T21:57:23.9594221Z  at 
> java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
> 2020-09-28T21:57:23.9598708Z  at 
> java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)
> 2020-09-28T21:57:23.9599269Z  at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)
> 2020-09-28T21:57:23.9599778Z  at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2020-09-28T21:57:23.9600181Z  at java.lang.Thread.run(Thread.java:748)
> 2020-09-28T21:57:23.9600393Z 
> 2020-09-28T21:57:23.9601273Z "flink-taskexecutor-io-thread-5" #96 daemon 
> prio=5 os_prio=0 tid=0x00007f13d81da000 nid=0x5606 waiting on condition 
> [0x00007f13b954c000]
> 2020-09-28T21:57:23.9601763Z    java.lang.Thread.State: WAITING (parking)
> 2020-09-28T21:57:23.9602069Z  at sun.misc.Unsafe.park(Native Method)
> 2020-09-28T21:57:23.9602803Z  - parking to wait for  <0x0000000087a80860> (a 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
> 2020-09-28T21:57:23.9603323Z  at 
> java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> 2020-09-28T21:57:23.9603860Z  at 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
> 2020-09-28T21:57:23.9604439Z  at 
> java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
> 2020-09-28T21:57:23.9604935Z  at 
> java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)
> 2020-09-28T21:57:23.9605438Z  at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)
> 2020-09-28T21:57:23.9605929Z  at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2020-09-28T21:57:23.9606352Z  at java.lang.Thread.run(Thread.java:748)
> 2020-09-28T21:57:23.9606549Z 
> 2020-09-28T21:57:23.9607253Z "flink-taskexecutor-io-thread-4" #95 daemon 
> prio=5 os_prio=0 tid=0x00007f13d817e800 nid=0x5605 waiting on condition 
> [0x00007f13ba459000]
> 2020-09-28T21:57:23.9607730Z    java.lang.Thread.State: WAITING (parking)
> 2020-09-28T21:57:23.9608020Z  at sun.misc.Unsafe.park(Native Method)
> 2020-09-28T21:57:23.9608696Z  - parking to wait for  <0x0000000087a80860> (a 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
> 2020-09-28T21:57:23.9609192Z  at 
> java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> 2020-09-28T21:57:23.9609749Z  at 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
> 2020-09-28T21:57:23.9610323Z  at 
> java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
> 2020-09-28T21:57:23.9610800Z  at 
> java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)
> 2020-09-28T21:57:23.9611507Z  at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)
> 2020-09-28T21:57:23.9612018Z  at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2020-09-28T21:57:23.9612415Z  at java.lang.Thread.run(Thread.java:748)
> 2020-09-28T21:57:23.9612629Z 
> 2020-09-28T21:57:23.9613327Z "flink-taskexecutor-io-thread-3" #94 daemon 
> prio=5 os_prio=0 tid=0x00007f13d817d800 nid=0x5604 waiting on condition 
> [0x00007f13b8d44000]
> 2020-09-28T21:57:23.9613912Z    java.lang.Thread.State: WAITING (parking)
> 2020-09-28T21:57:23.9614219Z  at sun.misc.Unsafe.park(Native Method)
> 2020-09-28T21:57:23.9614908Z  - parking to wait for  <0x0000000087a80860> (a 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
> 2020-09-28T21:57:23.9615418Z  at 
> java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> 2020-09-28T21:57:23.9615968Z  at 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
> 2020-09-28T21:57:23.9616525Z  at 
> java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
> 2020-09-28T21:57:23.9617016Z  at 
> java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)
> 2020-09-28T21:57:23.9617515Z  at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)
> 2020-09-28T21:57:23.9618002Z  at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2020-09-28T21:57:23.9618419Z  at java.lang.Thread.run(Thread.java:748)
> 2020-09-28T21:57:23.9618620Z 
> 2020-09-28T21:57:23.9619297Z "flink-taskexecutor-io-thread-2" #93 daemon 
> prio=5 os_prio=0 tid=0x00007f13d817c800 nid=0x5603 waiting on condition 
> [0x00007f13ba65b000]
> 2020-09-28T21:57:23.9620126Z    java.lang.Thread.State: WAITING (parking)
> 2020-09-28T21:57:23.9620429Z  at sun.misc.Unsafe.park(Native Method)
> 2020-09-28T21:57:23.9621171Z  - parking to wait for  <0x0000000087a80860> (a 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
> 2020-09-28T21:57:23.9621691Z  at 
> java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> 2020-09-28T21:57:23.9622227Z  at 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
> 2020-09-28T21:57:23.9622795Z  at 
> java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
> 2020-09-28T21:57:23.9623289Z  at 
> java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)
> 2020-09-28T21:57:23.9623772Z  at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)
> 2020-09-28T21:57:23.9624276Z  at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2020-09-28T21:57:23.9624689Z  at java.lang.Thread.run(Thread.java:748)
> 2020-09-28T21:57:23.9624887Z 
> 2020-09-28T21:57:23.9625567Z "flink-taskexecutor-io-thread-1" #92 daemon 
> prio=5 os_prio=0 tid=0x00007f13d8179800 nid=0x5602 waiting on condition 
> [0x00007f13ba75c000]
> 2020-09-28T21:57:23.9626029Z    java.lang.Thread.State: WAITING (parking)
> 2020-09-28T21:57:23.9626340Z  at sun.misc.Unsafe.park(Native Method)
> 2020-09-28T21:57:23.9627016Z  - parking to wait for  <0x0000000087a80860> (a 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
> 2020-09-28T21:57:23.9627506Z  at 
> java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> 2020-09-28T21:57:23.9628056Z  at 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
> 2020-09-28T21:57:23.9629291Z  at 
> java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
> 2020-09-28T21:57:23.9629807Z  at 
> java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)
> 2020-09-28T21:57:23.9630310Z  at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)
> 2020-09-28T21:57:23.9630817Z  at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2020-09-28T21:57:23.9631218Z  at java.lang.Thread.run(Thread.java:748)
> 2020-09-28T21:57:23.9631432Z 
> 2020-09-28T21:57:23.9632324Z "Flink-MetricRegistry-thread-1" #63 daemon 
> prio=5 os_prio=0 tid=0x00007f13dc02a000 nid=0x55e3 waiting on condition 
> [0x00007f13bacf1000]
> 2020-09-28T21:57:23.9632818Z    java.lang.Thread.State: TIMED_WAITING 
> (parking)
> 2020-09-28T21:57:23.9633136Z  at sun.misc.Unsafe.park(Native Method)
> 2020-09-28T21:57:23.9633803Z  - parking to wait for  <0x0000000087a828a8> (a 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
> 2020-09-28T21:57:23.9634320Z  at 
> java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
> 2020-09-28T21:57:23.9634992Z  at 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)
> 2020-09-28T21:57:23.9635629Z  at 
> java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1093)
> 2020-09-28T21:57:23.9636253Z  at 
> java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)
> 2020-09-28T21:57:23.9636809Z  at 
> java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)
> 2020-09-28T21:57:23.9637299Z  at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)
> 2020-09-28T21:57:23.9637806Z  at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2020-09-28T21:57:23.9638220Z  at java.lang.Thread.run(Thread.java:748)
> 2020-09-28T21:57:23.9638416Z 
> 2020-09-28T21:57:23.9639071Z "pool-2-thread-1" #60 prio=5 os_prio=0 
> tid=0x00007f13d8062000 nid=0x55e0 waiting on condition [0x00007f13bb3f4000]
> 2020-09-28T21:57:23.9639501Z    java.lang.Thread.State: WAITING (parking)
> 2020-09-28T21:57:23.9639806Z  at sun.misc.Unsafe.park(Native Method)
> 2020-09-28T21:57:23.9642766Z  - parking to wait for  <0x0000000087a82ae8> (a 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
> 2020-09-28T21:57:23.9646981Z  at 
> java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> 2020-09-28T21:57:23.9653370Z  at 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
> 2020-09-28T21:57:23.9661523Z  at 
> java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1081)
> 2020-09-28T21:57:23.9677357Z  at 
> java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)
> 2020-09-28T21:57:23.9679468Z  at 
> java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)
> 2020-09-28T21:57:23.9682652Z  at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)
> 2020-09-28T21:57:23.9683181Z  at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2020-09-28T21:57:23.9691283Z  at java.lang.Thread.run(Thread.java:748)
> 2020-09-28T21:57:23.9691503Z 
> 2020-09-28T21:57:23.9697420Z "jobmanager-future-thread-2" #57 daemon prio=5 
> os_prio=0 tid=0x00007f13d8057800 nid=0x55dd waiting on condition 
> [0x00007f13bb2f3000]
> 2020-09-28T21:57:23.9697929Z    java.lang.Thread.State: WAITING (parking)
> 2020-09-28T21:57:23.9698233Z  at sun.misc.Unsafe.park(Native Method)
> 2020-09-28T21:57:23.9698936Z  - parking to wait for  <0x0000000087a82d48> (a 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
> 2020-09-28T21:57:23.9699453Z  at 
> java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> 2020-09-28T21:57:23.9699993Z  at 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
> 2020-09-28T21:57:23.9700634Z  at 
> java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088)
> 2020-09-28T21:57:23.9706073Z  at 
> java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)
> 2020-09-28T21:57:23.9706660Z  at 
> java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)
> 2020-09-28T21:57:23.9708027Z  at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)
> 2020-09-28T21:57:23.9708690Z  at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2020-09-28T21:57:23.9709275Z  at java.lang.Thread.run(Thread.java:748)
> 2020-09-28T21:57:23.9709496Z 
> 2020-09-28T21:57:23.9710354Z "jobmanager-future-thread-1" #52 daemon prio=5 
> os_prio=0 tid=0x00007f13fc006000 nid=0x55ce waiting on condition 
> [0x00007f13bb1f2000]
> 2020-09-28T21:57:23.9711981Z    java.lang.Thread.State: TIMED_WAITING 
> (parking)
> 2020-09-28T21:57:23.9712340Z  at sun.misc.Unsafe.park(Native Method)
> 2020-09-28T21:57:23.9713125Z  - parking to wait for  <0x0000000087a82d48> (a 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
> 2020-09-28T21:57:23.9713788Z  at 
> java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
> 2020-09-28T21:57:23.9714363Z  at 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)
> 2020-09-28T21:57:23.9714998Z  at 
> java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1093)
> 2020-09-28T21:57:23.9715632Z  at 
> java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)
> 2020-09-28T21:57:23.9716545Z  at 
> java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)
> 2020-09-28T21:57:23.9717049Z  at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)
> 2020-09-28T21:57:23.9717562Z  at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2020-09-28T21:57:23.9718752Z  at java.lang.Thread.run(Thread.java:748)
> 2020-09-28T21:57:23.9718980Z 
> 2020-09-28T21:57:23.9719773Z "mini-cluster-io-thread-8" #47 daemon prio=5 
> os_prio=0 tid=0x00007f13f0006800 nid=0x55c9 waiting on condition 
> [0x00007f13bb7f6000]
> 2020-09-28T21:57:23.9720529Z    java.lang.Thread.State: WAITING (parking)
> 2020-09-28T21:57:23.9720867Z  at sun.misc.Unsafe.park(Native Method)
> 2020-09-28T21:57:23.9721624Z  - parking to wait for  <0x0000000087a83170> (a 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
> 2020-09-28T21:57:23.9722132Z  at 
> java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> 2020-09-28T21:57:23.9722688Z  at 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
> 2020-09-28T21:57:23.9723258Z  at 
> java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
> 2020-09-28T21:57:23.9723734Z  at 
> java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)
> 2020-09-28T21:57:23.9724235Z  at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)
> 2020-09-28T21:57:23.9724748Z  at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2020-09-28T21:57:23.9725149Z  at java.lang.Thread.run(Thread.java:748)
> 2020-09-28T21:57:23.9725990Z 
> 2020-09-28T21:57:23.9727058Z "mini-cluster-io-thread-7" #46 daemon prio=5 
> os_prio=0 tid=0x00007f13f0005000 nid=0x55c8 waiting on condition 
> [0x00007f13bb8f7000]
> 2020-09-28T21:57:23.9727545Z    java.lang.Thread.State: WAITING (parking)
> 2020-09-28T21:57:23.9727864Z  at sun.misc.Unsafe.park(Native Method)
> 2020-09-28T21:57:23.9728536Z  - parking to wait for  <0x0000000087a83170> (a 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
> 2020-09-28T21:57:23.9729060Z  at 
> java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> 2020-09-28T21:57:23.9729614Z  at 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
> 2020-09-28T21:57:23.9730172Z  at 
> java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
> 2020-09-28T21:57:23.9730674Z  at 
> java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)
> 2020-09-28T21:57:23.9731176Z  at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)
> 2020-09-28T21:57:23.9731668Z  at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2020-09-28T21:57:23.9732083Z  at java.lang.Thread.run(Thread.java:748)
> 2020-09-28T21:57:23.9732279Z 
> 2020-09-28T21:57:23.9733140Z "mini-cluster-io-thread-6" #45 daemon prio=5 
> os_prio=0 tid=0x00007f13e0006000 nid=0x55c7 waiting on condition 
> [0x00007f13bb9f8000]
> 2020-09-28T21:57:23.9733609Z    java.lang.Thread.State: WAITING (parking)
> 2020-09-28T21:57:23.9733902Z  at sun.misc.Unsafe.park(Native Method)
> 2020-09-28T21:57:23.9734576Z  - parking to wait for  <0x0000000087a83170> (a 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
> 2020-09-28T21:57:23.9735083Z  at 
> java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> 2020-09-28T21:57:23.9735712Z  at 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
> 2020-09-28T21:57:23.9749725Z  at 
> java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
> 2020-09-28T21:57:23.9750270Z  at 
> java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)
> 2020-09-28T21:57:23.9750760Z  at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)
> 2020-09-28T21:57:23.9751282Z  at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2020-09-28T21:57:23.9751701Z  at java.lang.Thread.run(Thread.java:748)
> 2020-09-28T21:57:23.9751899Z 
> 2020-09-28T21:57:23.9752776Z "mini-cluster-io-thread-5" #44 daemon prio=5 
> os_prio=0 tid=0x00007f13e4002800 nid=0x55c6 waiting on condition 
> [0x00007f13bbaf9000]
> 2020-09-28T21:57:23.9753233Z    java.lang.Thread.State: WAITING (parking)
> 2020-09-28T21:57:23.9753540Z  at sun.misc.Unsafe.park(Native Method)
> 2020-09-28T21:57:23.9754248Z  - parking to wait for  <0x0000000087a83170> (a 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
> 2020-09-28T21:57:23.9754743Z  at 
> java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> 2020-09-28T21:57:23.9755298Z  at 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
> 2020-09-28T21:57:23.9755868Z  at 
> java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
> 2020-09-28T21:57:23.9756352Z  at 
> java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)
> 2020-09-28T21:57:23.9756854Z  at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)
> 2020-09-28T21:57:23.9757357Z  at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2020-09-28T21:57:23.9757757Z  at java.lang.Thread.run(Thread.java:748)
> 2020-09-28T21:57:23.9757970Z 
> 2020-09-28T21:57:23.9758625Z "mini-cluster-io-thread-4" #43 daemon prio=5 
> os_prio=0 tid=0x00007f13bd54c000 nid=0x55c5 waiting on condition 
> [0x00007f13bbbfa000]
> 2020-09-28T21:57:23.9759097Z    java.lang.Thread.State: WAITING (parking)
> 2020-09-28T21:57:23.9759406Z  at sun.misc.Unsafe.park(Native Method)
> 2020-09-28T21:57:23.9760067Z  - parking to wait for  <0x0000000087a83170> (a 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
> 2020-09-28T21:57:23.9760573Z  at 
> java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> 2020-09-28T21:57:23.9761126Z  at 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
> 2020-09-28T21:57:23.9761689Z  at 
> java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
> 2020-09-28T21:57:23.9762182Z  at 
> java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)
> 2020-09-28T21:57:23.9762683Z  at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)
> 2020-09-28T21:57:23.9763174Z  at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2020-09-28T21:57:23.9763595Z  at java.lang.Thread.run(Thread.java:748)
> 2020-09-28T21:57:23.9763791Z 
> 2020-09-28T21:57:23.9764454Z "mini-cluster-io-thread-3" #42 daemon prio=5 
> os_prio=0 tid=0x00007f13d801c800 nid=0x55c4 waiting on condition 
> [0x00007f13bbcfb000]
> 2020-09-28T21:57:23.9764922Z    java.lang.Thread.State: WAITING (parking)
> 2020-09-28T21:57:23.9765214Z  at sun.misc.Unsafe.park(Native Method)
> 2020-09-28T21:57:23.9765885Z  - parking to wait for  <0x0000000087a83170> (a 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
> 2020-09-28T21:57:23.9766588Z  at 
> java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> 2020-09-28T21:57:23.9767126Z  at 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
> 2020-09-28T21:57:23.9767696Z  at 
> java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
> 2020-09-28T21:57:23.9769412Z  at 
> java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)
> 2020-09-28T21:57:23.9770047Z  at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)
> 2020-09-28T21:57:23.9770555Z  at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2020-09-28T21:57:23.9770973Z  at java.lang.Thread.run(Thread.java:748)
> 2020-09-28T21:57:23.9771170Z 
> 2020-09-28T21:57:23.9771943Z "mini-cluster-io-thread-2" #41 daemon prio=5 
> os_prio=0 tid=0x00007f13bd547000 nid=0x55c3 waiting on condition 
> [0x00007f13bbdfc000]
> 2020-09-28T21:57:23.9772402Z    java.lang.Thread.State: WAITING (parking)
> 2020-09-28T21:57:23.9772708Z  at sun.misc.Unsafe.park(Native Method)
> 2020-09-28T21:57:23.9773371Z  - parking to wait for  <0x0000000087a83170> (a 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
> 2020-09-28T21:57:23.9773881Z  at 
> java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> 2020-09-28T21:57:23.9774436Z  at 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
> 2020-09-28T21:57:23.9775011Z  at 
> java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
> 2020-09-28T21:57:23.9775487Z  at 
> java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)
> 2020-09-28T21:57:23.9775988Z  at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)
> 2020-09-28T21:57:23.9776493Z  at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2020-09-28T21:57:23.9776892Z  at java.lang.Thread.run(Thread.java:748)
> 2020-09-28T21:57:23.9777107Z 
> 2020-09-28T21:57:23.9777787Z "Flink-DispatcherRestEndpoint-thread-1" #39 
> daemon prio=5 os_prio=0 tid=0x00007f13bd529000 nid=0x55c1 waiting on 
> condition [0x00007f13bbefd000]
> 2020-09-28T21:57:23.9778283Z    java.lang.Thread.State: TIMED_WAITING 
> (parking)
> 2020-09-28T21:57:23.9778601Z  at sun.misc.Unsafe.park(Native Method)
> 2020-09-28T21:57:23.9779258Z  - parking to wait for  <0x0000000087a80e70> (a 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
> 2020-09-28T21:57:23.9779777Z  at 
> java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
> 2020-09-28T21:57:23.9780336Z  at 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)
> 2020-09-28T21:57:23.9780990Z  at 
> java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1093)
> 2020-09-28T21:57:23.9781613Z  at 
> java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)
> 2020-09-28T21:57:23.9782178Z  at 
> java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)
> 2020-09-28T21:57:23.9782664Z  at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)
> 2020-09-28T21:57:23.9783171Z  at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2020-09-28T21:57:23.9783581Z  at java.lang.Thread.run(Thread.java:748)
> 2020-09-28T21:57:23.9783777Z 
> 2020-09-28T21:57:23.9784443Z "mini-cluster-io-thread-1" #38 daemon prio=5 
> os_prio=0 tid=0x00007f1414c2c000 nid=0x55c0 waiting on condition 
> [0x00007f13bbffe000]
> 2020-09-28T21:57:23.9784895Z    java.lang.Thread.State: WAITING (parking)
> 2020-09-28T21:57:23.9785201Z  at sun.misc.Unsafe.park(Native Method)
> 2020-09-28T21:57:23.9785857Z  - parking to wait for  <0x0000000087a83170> (a 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
> 2020-09-28T21:57:23.9786360Z  at 
> java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> 2020-09-28T21:57:23.9787010Z  at 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
> 2020-09-28T21:57:23.9787581Z  at 
> java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
> 2020-09-28T21:57:23.9788059Z  at 
> java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)
> 2020-09-28T21:57:23.9788713Z  at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)
> 2020-09-28T21:57:23.9789309Z  at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2020-09-28T21:57:23.9789709Z  at java.lang.Thread.run(Thread.java:748)
> 2020-09-28T21:57:23.9789923Z 
> 2020-09-28T21:57:23.9790639Z "flink-rest-server-netty-boss-thread-1" #37 
> daemon prio=5 os_prio=0 tid=0x00007f13bd523800 nid=0x55bf runnable 
> [0x00007f13c48e6000]
> 2020-09-28T21:57:23.9791090Z    java.lang.Thread.State: RUNNABLE
> 2020-09-28T21:57:23.9791576Z  at 
> sun.nio.ch.EPollArrayWrapper.epollWait(Native Method)
> 2020-09-28T21:57:23.9792121Z  at 
> sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269)
> 2020-09-28T21:57:23.9792575Z  at 
> sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93)
> 2020-09-28T21:57:23.9793006Z  at 
> sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86)
> 2020-09-28T21:57:23.9793799Z  - locked <0x0000000087a842d0> (a 
> org.apache.flink.shaded.netty4.io.netty.channel.nio.SelectedSelectionKeySet)
> 2020-09-28T21:57:23.9794485Z  - locked <0x0000000087a842c0> (a 
> java.util.Collections$UnmodifiableSet)
> 2020-09-28T21:57:23.9795075Z  - locked <0x0000000087a84278> (a 
> sun.nio.ch.EPollSelectorImpl)
> 2020-09-28T21:57:23.9795464Z  at 
> sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97)
> 2020-09-28T21:57:23.9796024Z  at 
> org.apache.flink.shaded.netty4.io.netty.channel.nio.SelectedSelectionKeySetSelector.select(SelectedSelectionKeySetSelector.java:62)
> 2020-09-28T21:57:23.9796658Z  at 
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.select(NioEventLoop.java:806)
> 2020-09-28T21:57:23.9797222Z  at 
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:454)
> 2020-09-28T21:57:23.9798242Z  at 
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:918)
> 2020-09-28T21:57:23.9798893Z  at 
> org.apache.flink.shaded.netty4.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
> 2020-09-28T21:57:23.9799364Z  at java.lang.Thread.run(Thread.java:748)
> 2020-09-28T21:57:23.9799578Z 
> 2020-09-28T21:57:23.9799949Z "IOManager reader thread #1" #31 daemon prio=5 
> os_prio=0 tid=0x00007f1415151800 nid=0x55bb waiting on condition 
> [0x00007f13c47be000]
> 2020-09-28T21:57:23.9800407Z    java.lang.Thread.State: WAITING (parking)
> 2020-09-28T21:57:23.9800699Z  at sun.misc.Unsafe.park(Native Method)
> 2020-09-28T21:57:23.9801928Z  - parking to wait for  <0x0000000087a84538> (a 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
> 2020-09-28T21:57:23.9803039Z  at 
> java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> 2020-09-28T21:57:23.9803965Z  at 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
> 2020-09-28T21:57:23.9804873Z  at 
> java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
> 2020-09-28T21:57:23.9805730Z  at 
> org.apache.flink.runtime.io.disk.iomanager.IOManagerAsync$ReaderThread.run(IOManagerAsync.java:354)
> 2020-09-28T21:57:23.9806066Z 
> 2020-09-28T21:57:23.9806445Z "IOManager writer thread #1" #30 daemon prio=5 
> os_prio=0 tid=0x00007f141514f000 nid=0x55ba waiting on condition 
> [0x00007f13c4afa000]
> 2020-09-28T21:57:23.9806912Z    java.lang.Thread.State: WAITING (parking)
> 2020-09-28T21:57:23.9807204Z  at sun.misc.Unsafe.park(Native Method)
> 2020-09-28T21:57:23.9807993Z  - parking to wait for  <0x0000000087a84740> (a 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
> 2020-09-28T21:57:23.9808490Z  at 
> java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> 2020-09-28T21:57:23.9809192Z  at 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
> 2020-09-28T21:57:23.9809764Z  at 
> java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
> 2020-09-28T21:57:23.9810289Z  at 
> org.apache.flink.runtime.io.disk.iomanager.IOManagerAsync$WriterThread.run(IOManagerAsync.java:460)
> 2020-09-28T21:57:23.9810634Z 
> 2020-09-28T21:57:23.9811266Z "Timer-2" #28 daemon prio=5 os_prio=0 
> tid=0x00007f14150f9000 nid=0x55b9 in Object.wait() [0x00007f13c49e7000]
> 2020-09-28T21:57:23.9811814Z    java.lang.Thread.State: TIMED_WAITING (on 
> object monitor)
> 2020-09-28T21:57:23.9812154Z  at java.lang.Object.wait(Native Method)
> 2020-09-28T21:57:23.9812694Z  - waiting on <0x0000000087a84948> (a 
> java.util.TaskQueue)
> 2020-09-28T21:57:23.9813061Z  at 
> java.util.TimerThread.mainLoop(Timer.java:552)
> 2020-09-28T21:57:23.9813613Z  - locked <0x0000000087a84948> (a 
> java.util.TaskQueue)
> 2020-09-28T21:57:23.9813947Z  at java.util.TimerThread.run(Timer.java:505)
> 2020-09-28T21:57:23.9814173Z 
> 2020-09-28T21:57:23.9814750Z "Timer-1" #26 daemon prio=5 os_prio=0 
> tid=0x00007f14150f6000 nid=0x55b8 in Object.wait() [0x00007f13c4bfb000]
> 2020-09-28T21:57:23.9815208Z    java.lang.Thread.State: TIMED_WAITING (on 
> object monitor)
> 2020-09-28T21:57:23.9815545Z  at java.lang.Object.wait(Native Method)
> 2020-09-28T21:57:23.9816051Z  - waiting on <0x0000000087a84b28> (a 
> java.util.TaskQueue)
> 2020-09-28T21:57:23.9816415Z  at 
> java.util.TimerThread.mainLoop(Timer.java:552)
> 2020-09-28T21:57:23.9817018Z  - locked <0x0000000087a84b28> (a 
> java.util.TaskQueue)
> 2020-09-28T21:57:23.9817360Z  at java.util.TimerThread.run(Timer.java:505)
> 2020-09-28T21:57:23.9817578Z 
> 2020-09-28T21:57:23.9817929Z "BLOB Server listener at 46483" #22 daemon 
> prio=5 os_prio=0 tid=0x00007f14150f3000 nid=0x55b7 runnable 
> [0x00007f13c4cfc000]
> 2020-09-28T21:57:23.9818357Z    java.lang.Thread.State: RUNNABLE
> 2020-09-28T21:57:23.9818684Z  at java.net.PlainSocketImpl.socketAccept(Native 
> Method)
> 2020-09-28T21:57:23.9819087Z  at 
> java.net.AbstractPlainSocketImpl.accept(AbstractPlainSocketImpl.java:409)
> 2020-09-28T21:57:23.9819551Z  at 
> java.net.ServerSocket.implAccept(ServerSocket.java:560)
> 2020-09-28T21:57:23.9819936Z  at 
> java.net.ServerSocket.accept(ServerSocket.java:528)
> 2020-09-28T21:57:23.9820364Z  at 
> org.apache.flink.runtime.blob.BlobServer.run(BlobServer.java:262)
> 2020-09-28T21:57:23.9820621Z 
> 2020-09-28T21:57:23.9821232Z "Timer-0" #23 daemon prio=5 os_prio=0 
> tid=0x00007f14150a1800 nid=0x55b6 in Object.wait() [0x00007f13c4ffd000]
> 2020-09-28T21:57:23.9821695Z    java.lang.Thread.State: TIMED_WAITING (on 
> object monitor)
> 2020-09-28T21:57:23.9822017Z  at java.lang.Object.wait(Native Method)
> 2020-09-28T21:57:23.9822540Z  - waiting on <0x0000000087a85168> (a 
> java.util.TaskQueue)
> 2020-09-28T21:57:23.9822906Z  at 
> java.util.TimerThread.mainLoop(Timer.java:552)
> 2020-09-28T21:57:23.9823440Z  - locked <0x0000000087a85168> (a 
> java.util.TaskQueue)
> 2020-09-28T21:57:23.9823789Z  at java.util.TimerThread.run(Timer.java:505)
> 2020-09-28T21:57:23.9823999Z 
> 2020-09-28T21:57:23.9824635Z "flink-metrics-scheduler-1" #18 prio=5 os_prio=0 
> tid=0x00007f1415064800 nid=0x55b2 waiting on condition [0x00007f13e83f7000]
> 2020-09-28T21:57:23.9825085Z    java.lang.Thread.State: TIMED_WAITING 
> (sleeping)
> 2020-09-28T21:57:23.9825404Z  at java.lang.Thread.sleep(Native Method)
> 2020-09-28T21:57:23.9825820Z  at 
> akka.actor.LightArrayRevolverScheduler.waitNanos(LightArrayRevolverScheduler.scala:85)
> 2020-09-28T21:57:23.9826362Z  at 
> akka.actor.LightArrayRevolverScheduler$$anon$4.nextTick(LightArrayRevolverScheduler.scala:265)
> 2020-09-28T21:57:23.9827122Z  at 
> akka.actor.LightArrayRevolverScheduler$$anon$4.run(LightArrayRevolverScheduler.scala:235)
> 2020-09-28T21:57:23.9827547Z  at java.lang.Thread.run(Thread.java:748)
> 2020-09-28T21:57:23.9827758Z 
> 2020-09-28T21:57:23.9829451Z "flink-scheduler-1" #14 prio=5 os_prio=0 
> tid=0x00007f1414c85000 nid=0x55ae waiting on condition [0x00007f13e89fb000]
> 2020-09-28T21:57:23.9829947Z    java.lang.Thread.State: TIMED_WAITING 
> (sleeping)
> 2020-09-28T21:57:23.9830402Z  at java.lang.Thread.sleep(Native Method)
> 2020-09-28T21:57:23.9830792Z  at 
> akka.actor.LightArrayRevolverScheduler.waitNanos(LightArrayRevolverScheduler.scala:85)
> 2020-09-28T21:57:23.9831345Z  at 
> akka.actor.LightArrayRevolverScheduler$$anon$4.nextTick(LightArrayRevolverScheduler.scala:265)
> 2020-09-28T21:57:23.9831901Z  at 
> akka.actor.LightArrayRevolverScheduler$$anon$4.run(LightArrayRevolverScheduler.scala:235)
> 2020-09-28T21:57:23.9832320Z  at java.lang.Thread.run(Thread.java:748)
> 2020-09-28T21:57:23.9832599Z 
> 2020-09-28T21:57:23.9832943Z "process reaper" #11 daemon prio=10 os_prio=0 
> tid=0x00007f13c8030000 nid=0x55ab waiting on condition [0x00007f13e9439000]
> 2020-09-28T21:57:23.9833394Z    java.lang.Thread.State: TIMED_WAITING 
> (parking)
> 2020-09-28T21:57:23.9833709Z  at sun.misc.Unsafe.park(Native Method)
> 2020-09-28T21:57:23.9834451Z  - parking to wait for  <0x000000008006e918> (a 
> java.util.concurrent.SynchronousQueue$TransferStack)
> 2020-09-28T21:57:23.9834943Z  at 
> java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
> 2020-09-28T21:57:23.9835465Z  at 
> java.util.concurrent.SynchronousQueue$TransferStack.awaitFulfill(SynchronousQueue.java:460)
> 2020-09-28T21:57:23.9836000Z  at 
> java.util.concurrent.SynchronousQueue$TransferStack.transfer(SynchronousQueue.java:362)
> 2020-09-28T21:57:23.9836502Z  at 
> java.util.concurrent.SynchronousQueue.poll(SynchronousQueue.java:941)
> 2020-09-28T21:57:23.9836982Z  at 
> java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1073)
> 2020-09-28T21:57:23.9837474Z  at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)
> 2020-09-28T21:57:23.9837981Z  at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2020-09-28T21:57:23.9838391Z  at java.lang.Thread.run(Thread.java:748)
> 2020-09-28T21:57:23.9838588Z 
> 2020-09-28T21:57:23.9839272Z "surefire-forkedjvm-ping-30s" #10 daemon prio=5 
> os_prio=0 tid=0x00007f141434a800 nid=0x55a8 waiting on condition 
> [0x00007f13e99c9000]
> 2020-09-28T21:57:23.9839743Z    java.lang.Thread.State: TIMED_WAITING 
> (parking)
> 2020-09-28T21:57:23.9840063Z  at sun.misc.Unsafe.park(Native Method)
> 2020-09-28T21:57:23.9840727Z  - parking to wait for  <0x000000008006eb78> (a 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
> 2020-09-28T21:57:23.9841241Z  at 
> java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
> 2020-09-28T21:57:23.9841815Z  at 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)
> 2020-09-28T21:57:23.9842470Z  at 
> java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1093)
> 2020-09-28T21:57:23.9843078Z  at 
> java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)
> 2020-09-28T21:57:23.9843632Z  at 
> java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)
> 2020-09-28T21:57:23.9844245Z  at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)
> 2020-09-28T21:57:23.9844753Z  at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2020-09-28T21:57:23.9845164Z  at java.lang.Thread.run(Thread.java:748)
> 2020-09-28T21:57:23.9845360Z 
> 2020-09-28T21:57:23.9846040Z "surefire-forkedjvm-command-thread" #9 daemon 
> prio=5 os_prio=0 tid=0x00007f1414333800 nid=0x55a7 runnable 
> [0x00007f14041f8000]
> 2020-09-28T21:57:23.9846483Z    java.lang.Thread.State: RUNNABLE
> 2020-09-28T21:57:23.9846787Z  at java.io.FileInputStream.readBytes(Native 
> Method)
> 2020-09-28T21:57:23.9847158Z  at 
> java.io.FileInputStream.read(FileInputStream.java:255)
> 2020-09-28T21:57:23.9847566Z  at 
> java.io.BufferedInputStream.fill(BufferedInputStream.java:246)
> 2020-09-28T21:57:23.9848006Z  at 
> java.io.BufferedInputStream.read(BufferedInputStream.java:265)
> 2020-09-28T21:57:23.9848623Z  - locked <0x000000008006ee18> (a 
> java.io.BufferedInputStream)
> 2020-09-28T21:57:23.9849002Z  at 
> java.io.DataInputStream.readInt(DataInputStream.java:387)
> 2020-09-28T21:57:23.9849489Z  at 
> org.apache.maven.surefire.booter.MasterProcessCommand.decode(MasterProcessCommand.java:115)
> 2020-09-28T21:57:23.9850148Z  at 
> org.apache.maven.surefire.booter.CommandReader$CommandRunnable.run(CommandReader.java:391)
> 2020-09-28T21:57:23.9850574Z  at java.lang.Thread.run(Thread.java:748)
> 2020-09-28T21:57:23.9850786Z 
> 2020-09-28T21:57:23.9851108Z "Service Thread" #8 daemon prio=9 os_prio=0 
> tid=0x00007f1414202800 nid=0x55a5 runnable [0x0000000000000000]
> 2020-09-28T21:57:23.9851509Z    java.lang.Thread.State: RUNNABLE
> 2020-09-28T21:57:23.9851751Z 
> 2020-09-28T21:57:23.9852108Z "C1 CompilerThread1" #7 daemon prio=9 os_prio=0 
> tid=0x00007f14141ff800 nid=0x55a4 waiting on condition [0x0000000000000000]
> 2020-09-28T21:57:23.9852538Z    java.lang.Thread.State: RUNNABLE
> 2020-09-28T21:57:23.9852718Z 
> 2020-09-28T21:57:23.9853073Z "C2 CompilerThread0" #6 daemon prio=9 os_prio=0 
> tid=0x00007f14141fd000 nid=0x55a3 waiting on condition [0x0000000000000000]
> 2020-09-28T21:57:23.9853482Z    java.lang.Thread.State: RUNNABLE
> 2020-09-28T21:57:23.9853684Z 
> 2020-09-28T21:57:23.9854005Z "Signal Dispatcher" #5 daemon prio=9 os_prio=0 
> tid=0x00007f14141fb000 nid=0x55a2 runnable [0x0000000000000000]
> 2020-09-28T21:57:23.9854406Z    java.lang.Thread.State: RUNNABLE
> 2020-09-28T21:57:23.9854585Z 
> 2020-09-28T21:57:23.9854979Z "Surrogate Locker Thread (Concurrent GC)" #4 
> daemon prio=9 os_prio=0 tid=0x00007f14141f9800 nid=0x55a1 waiting on 
> condition [0x0000000000000000]
> 2020-09-28T21:57:23.9855438Z    java.lang.Thread.State: RUNNABLE
> 2020-09-28T21:57:23.9855621Z 
> 2020-09-28T21:57:23.9855962Z "Finalizer" #3 daemon prio=8 os_prio=0 
> tid=0x00007f14141c9800 nid=0x55a0 in Object.wait() [0x00007f14182f8000]
> 2020-09-28T21:57:23.9856393Z    java.lang.Thread.State: WAITING (on object 
> monitor)
> 2020-09-28T21:57:23.9856718Z  at java.lang.Object.wait(Native Method)
> 2020-09-28T21:57:23.9857330Z  - waiting on <0x000000008006f798> (a 
> java.lang.ref.ReferenceQueue$Lock)
> 2020-09-28T21:57:23.9857741Z  at 
> java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:144)
> 2020-09-28T21:57:23.9858369Z  - locked <0x000000008006f798> (a 
> java.lang.ref.ReferenceQueue$Lock)
> 2020-09-28T21:57:23.9858783Z  at 
> java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:165)
> 2020-09-28T21:57:23.9859202Z  at 
> java.lang.ref.Finalizer$FinalizerThread.run(Finalizer.java:216)
> 2020-09-28T21:57:23.9859468Z 
> 2020-09-28T21:57:23.9859810Z "Reference Handler" #2 daemon prio=10 os_prio=0 
> tid=0x00007f14141c5000 nid=0x559f in Object.wait() [0x00007f14183f9000]
> 2020-09-28T21:57:23.9860267Z    java.lang.Thread.State: WAITING (on object 
> monitor)
> 2020-09-28T21:57:23.9860604Z  at java.lang.Object.wait(Native Method)
> 2020-09-28T21:57:23.9860900Z  at java.lang.Object.wait(Object.java:502)
> 2020-09-28T21:57:23.9861280Z  at 
> java.lang.ref.Reference.tryHandlePending(Reference.java:191)
> 2020-09-28T21:57:23.9861895Z  - locked <0x000000008006f950> (a 
> java.lang.ref.Reference$Lock)
> 2020-09-28T21:57:23.9862297Z  at 
> java.lang.ref.Reference$ReferenceHandler.run(Reference.java:153)
> 2020-09-28T21:57:23.9862564Z 
> 2020-09-28T21:57:23.9862875Z "main" #1 prio=5 os_prio=0 
> tid=0x00007f141400b800 nid=0x5596 waiting on condition [0x00007f141de0b000]
> 2020-09-28T21:57:23.9879457Z    java.lang.Thread.State: WAITING (parking)
> 2020-09-28T21:57:23.9879924Z  at sun.misc.Unsafe.park(Native Method)
> 2020-09-28T21:57:23.9880710Z  - parking to wait for  <0x0000000087a855c8> (a 
> java.util.concurrent.CompletableFuture$Signaller)
> 2020-09-28T21:57:23.9881191Z  at 
> java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> 2020-09-28T21:57:23.9881680Z  at 
> java.util.concurrent.CompletableFuture$Signaller.block(CompletableFuture.java:1707)
> 2020-09-28T21:57:23.9882170Z  at 
> java.util.concurrent.ForkJoinPool.managedBlock(ForkJoinPool.java:3323)
> 2020-09-28T21:57:23.9882650Z  at 
> java.util.concurrent.CompletableFuture.waitingGet(CompletableFuture.java:1742)
> 2020-09-28T21:57:23.9883135Z  at 
> java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908)
> 2020-09-28T21:57:23.9883627Z  at 
> org.apache.flink.runtime.minicluster.MiniCluster.executeJobBlocking(MiniCluster.java:671)
> 2020-09-28T21:57:23.9884338Z  at 
> org.apache.flink.streaming.util.TestStreamEnvironment.execute(TestStreamEnvironment.java:81)
> 2020-09-28T21:57:23.9884947Z  at 
> org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1706)
> 2020-09-28T21:57:23.9885589Z  at 
> org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1688)
> 2020-09-28T21:57:23.9886253Z  at 
> org.apache.flink.connector.base.source.reader.CoordinatedSourceITCase.executeAndVerify(CoordinatedSourceITCase.java:84)
> 2020-09-28T21:57:23.9887031Z  at 
> org.apache.flink.connector.base.source.reader.CoordinatedSourceITCase.testEnumeratorReaderCommunication(CoordinatedSourceITCase.java:52)
> 2020-09-28T21:57:23.9887586Z  at 
> sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 2020-09-28T21:57:23.9888010Z  at 
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> 2020-09-28T21:57:23.9888533Z  at 
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 2020-09-28T21:57:23.9888992Z  at 
> java.lang.reflect.Method.invoke(Method.java:498)
> 2020-09-28T21:57:23.9889427Z  at 
> org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
> 2020-09-28T21:57:23.9889947Z  at 
> org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
> 2020-09-28T21:57:23.9890464Z  at 
> org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
> 2020-09-28T21:57:23.9890962Z  at 
> org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
> 2020-09-28T21:57:23.9891430Z  at 
> org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
> 2020-09-28T21:57:23.9891821Z  at 
> org.junit.rules.RunRules.evaluate(RunRules.java:20)
> 2020-09-28T21:57:23.9892230Z  at 
> org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
> 2020-09-28T21:57:23.9892701Z  at 
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
> 2020-09-28T21:57:23.9893193Z  at 
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
> 2020-09-28T21:57:23.9893659Z  at 
> org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
> 2020-09-28T21:57:23.9894085Z  at 
> org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
> 2020-09-28T21:57:23.9894512Z  at 
> org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
> 2020-09-28T21:57:23.9894951Z  at 
> org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
> 2020-09-28T21:57:23.9895388Z  at 
> org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
> 2020-09-28T21:57:23.9895827Z  at 
> org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:48)
> 2020-09-28T21:57:23.9896286Z  at 
> org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:48)
> 2020-09-28T21:57:23.9896709Z  at 
> org.junit.rules.RunRules.evaluate(RunRules.java:20)
> 2020-09-28T21:57:23.9897093Z  at 
> org.junit.runners.ParentRunner.run(ParentRunner.java:363)
> 2020-09-28T21:57:23.9897553Z  at 
> org.apache.maven.surefire.junit4.JUnit4Provider.execute(JUnit4Provider.java:365)
> 2020-09-28T21:57:23.9898083Z  at 
> org.apache.maven.surefire.junit4.JUnit4Provider.executeWithRerun(JUnit4Provider.java:273)
> 2020-09-28T21:57:23.9898609Z  at 
> org.apache.maven.surefire.junit4.JUnit4Provider.executeTestSet(JUnit4Provider.java:238)
> 2020-09-28T21:57:23.9899132Z  at 
> org.apache.maven.surefire.junit4.JUnit4Provider.invoke(JUnit4Provider.java:159)
> 2020-09-28T21:57:23.9899683Z  at 
> org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java:384)
> 2020-09-28T21:57:23.9900239Z  at 
> org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:345)
> 2020-09-28T21:57:23.9900748Z  at 
> org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:126)
> 2020-09-28T21:57:23.9901234Z  at 
> org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:418)
> 2020-09-28T21:57:23.9901507Z 
> 2020-09-28T21:57:23.9901776Z "VM Thread" os_prio=0 tid=0x00007f14141bb800 
> nid=0x559e runnable 
> 2020-09-28T21:57:23.9901994Z 
> 2020-09-28T21:57:23.9902370Z "Gang worker#0 (Parallel GC Threads)" os_prio=0 
> tid=0x00007f1414020800 nid=0x5597 runnable 
> 2020-09-28T21:57:23.9902632Z 
> 2020-09-28T21:57:23.9902940Z "Gang worker#1 (Parallel GC Threads)" os_prio=0 
> tid=0x00007f1414022000 nid=0x5598 runnable 
> 2020-09-28T21:57:23.9903193Z 
> 2020-09-28T21:57:23.9903492Z "G1 Main Concurrent Mark GC Thread" os_prio=0 
> tid=0x00007f1414046000 nid=0x559c runnable 
> 2020-09-28T21:57:23.9903745Z 
> 2020-09-28T21:57:23.9904062Z "Gang worker#0 (G1 Parallel Marking Threads)" 
> os_prio=0 tid=0x00007f1414047800 nid=0x559d runnable 
> 2020-09-28T21:57:23.9904410Z 
> 2020-09-28T21:57:23.9904710Z "G1 Concurrent Refinement Thread#0" os_prio=0 
> tid=0x00007f1414028000 nid=0x559b runnable 
> 2020-09-28T21:57:23.9904964Z 
> 2020-09-28T21:57:23.9905265Z "G1 Concurrent Refinement Thread#1" os_prio=0 
> tid=0x00007f1414026000 nid=0x559a runnable 
> 2020-09-28T21:57:23.9905518Z 
> 2020-09-28T21:57:23.9905816Z "G1 Concurrent Refinement Thread#2" os_prio=0 
> tid=0x00007f1414024800 nid=0x5599 runnable 
> 2020-09-28T21:57:23.9906077Z 
> 2020-09-28T21:57:23.9906381Z "VM Periodic Task Thread" os_prio=0 
> tid=0x00007f1414205800 nid=0x55a6 waiting on condition 
> 2020-09-28T21:57:23.9906642Z 
> 2020-09-28T21:57:23.9906849Z JNI global references: 1426
> 2020-09-28T21:57:23.9907016Z 
> 2020-09-28T21:57:23.9907295Z 
> ==============================================================================
> 2020-09-28T21:57:23.9907632Z Printing stack trace of Java process 534
> 2020-09-28T21:57:23.9907981Z 
> ==============================================================================
> 2020-09-28T21:57:23.9909557Z Picked up JAVA_TOOL_OPTIONS: 
> -XX:+HeapDumpOnOutOfMemoryError
> 2020-09-28T21:57:24.2975554Z 2020-09-28 21:57:24
> 2020-09-28T21:57:24.2976240Z Full thread dump OpenJDK 64-Bit Server VM 
> (25.242-b08 mixed mode):
> 2020-09-28T21:57:24.2976578Z 
> 2020-09-28T21:57:24.2983040Z "Attach Listener" #321 daemon prio=9 os_prio=0 
> tid=0x00007f12fc005800 nid=0x6060 waiting on condition [0x0000000000000000]
> 2020-09-28T21:57:24.2983527Z    java.lang.Thread.State: RUNNABLE
> 2020-09-28T21:57:24.2983816Z 
> 2020-09-28T21:57:24.2984551Z "Thread-127" #319 daemon prio=5 os_prio=0 
> tid=0x00007f130c01d800 nid=0x5595 runnable [0x00007f12e7596000]
> 2020-09-28T21:57:24.2984969Z    java.lang.Thread.State: RUNNABLE
> 2020-09-28T21:57:24.2985285Z  at java.io.FileInputStream.readBytes(Native 
> Method)
> 2020-09-28T21:57:24.2985638Z  at 
> java.io.FileInputStream.read(FileInputStream.java:255)
> 2020-09-28T21:57:24.2986064Z  at 
> java.io.BufferedInputStream.read1(BufferedInputStream.java:284)
> 2020-09-28T21:57:24.2986504Z  at 
> java.io.BufferedInputStream.read(BufferedInputStream.java:345)
> 2020-09-28T21:57:24.2987176Z  - locked <0x00000000def7c180> (a 
> java.lang.UNIXProcess$ProcessPipeInputStream)
> 2020-09-28T21:57:24.2987606Z  at 
> sun.nio.cs.StreamDecoder.readBytes(StreamDecoder.java:284)
> 2020-09-28T21:57:24.2988006Z  at 
> sun.nio.cs.StreamDecoder.implRead(StreamDecoder.java:326)
> 2020-09-28T21:57:24.2988412Z  at 
> sun.nio.cs.StreamDecoder.read(StreamDecoder.java:178)
> 2020-09-28T21:57:24.2989286Z  - locked <0x00000000def81350> (a 
> java.io.InputStreamReader)
> 2020-09-28T21:57:24.2989683Z  at 
> java.io.InputStreamReader.read(InputStreamReader.java:184)
> 2020-09-28T21:57:24.2990090Z  at 
> java.io.BufferedReader.fill(BufferedReader.java:161)
> 2020-09-28T21:57:24.2990494Z  at 
> java.io.BufferedReader.readLine(BufferedReader.java:324)
> 2020-09-28T21:57:24.2991075Z  - locked <0x00000000def81350> (a 
> java.io.InputStreamReader)
> 2020-09-28T21:57:24.2991463Z  at 
> java.io.BufferedReader.readLine(BufferedReader.java:389)
> 2020-09-28T21:57:24.2991970Z  at 
> org.apache.maven.surefire.shade.org.apache.maven.shared.utils.cli.StreamPumper.run(StreamPumper.java:76)
> 2020-09-28T21:57:24.2992319Z 
> 2020-09-28T21:57:24.2992910Z "Thread-126" #318 daemon prio=5 os_prio=0 
> tid=0x00007f130c01c800 nid=0x5594 runnable [0x00007f12e6f20000]
> 2020-09-28T21:57:24.2993306Z    java.lang.Thread.State: RUNNABLE
> 2020-09-28T21:57:24.2993623Z  at java.io.FileInputStream.readBytes(Native 
> Method)
> 2020-09-28T21:57:24.2993991Z  at 
> java.io.FileInputStream.read(FileInputStream.java:255)
> 2020-09-28T21:57:24.2994639Z  at 
> java.io.BufferedInputStream.read1(BufferedInputStream.java:284)
> 2020-09-28T21:57:24.2995083Z  at 
> java.io.BufferedInputStream.read(BufferedInputStream.java:345)
> 2020-09-28T21:57:24.2995782Z  - locked <0x00000000def7a0c0> (a 
> java.lang.UNIXProcess$ProcessPipeInputStream)
> 2020-09-28T21:57:24.2996197Z  at 
> sun.nio.cs.StreamDecoder.readBytes(StreamDecoder.java:284)
> 2020-09-28T21:57:24.2996610Z  at 
> sun.nio.cs.StreamDecoder.implRead(StreamDecoder.java:326)
> 2020-09-28T21:57:24.2997012Z  at 
> sun.nio.cs.StreamDecoder.read(StreamDecoder.java:178)
> 2020-09-28T21:57:24.2997729Z  - locked <0x00000000def7e748> (a 
> java.io.InputStreamReader)
> 2020-09-28T21:57:24.2998126Z  at 
> java.io.InputStreamReader.read(InputStreamReader.java:184)
> 2020-09-28T21:57:24.2998515Z  at 
> java.io.BufferedReader.fill(BufferedReader.java:161)
> 2020-09-28T21:57:24.2998920Z  at 
> java.io.BufferedReader.readLine(BufferedReader.java:324)
> 2020-09-28T21:57:24.2999510Z  - locked <0x00000000def7e748> (a 
> java.io.InputStreamReader)
> 2020-09-28T21:57:24.2999891Z  at 
> java.io.BufferedReader.readLine(BufferedReader.java:389)
> 2020-09-28T21:57:24.3000399Z  at 
> org.apache.maven.surefire.shade.org.apache.maven.shared.utils.cli.StreamPumper.run(StreamPumper.java:76)
> 2020-09-28T21:57:24.3000741Z 
> 2020-09-28T21:57:24.3001366Z "Thread-125" #317 daemon prio=5 os_prio=0 
> tid=0x00007f130c01b800 nid=0x5592 waiting on condition [0x00007f12e7495000]
> 2020-09-28T21:57:24.3001814Z    java.lang.Thread.State: WAITING (parking)
> 2020-09-28T21:57:24.3002105Z  at sun.misc.Unsafe.park(Native Method)
> 2020-09-28T21:57:24.3002716Z  - parking to wait for  <0x00000000dee62550> (a 
> java.util.concurrent.Semaphore$NonfairSync)
> 2020-09-28T21:57:24.3003178Z  at 
> java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> 2020-09-28T21:57:24.3003714Z  at 
> java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:836)
> 2020-09-28T21:57:24.3004379Z  at 
> java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedInterruptibly(AbstractQueuedSynchronizer.java:997)
> 2020-09-28T21:57:24.3005061Z  at 
> java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireSharedInterruptibly(AbstractQueuedSynchronizer.java:1304)
> 2020-09-28T21:57:24.3005589Z  at 
> java.util.concurrent.Semaphore.acquire(Semaphore.java:312)
> 2020-09-28T21:57:24.3006158Z  at 
> org.apache.maven.plugin.surefire.booterclient.lazytestprovider.TestLessInputStream.awaitNextCommand(TestLessInputStream.java:165)
> 2020-09-28T21:57:24.3006882Z  at 
> org.apache.maven.plugin.surefire.booterclient.lazytestprovider.TestLessInputStream.beforeNextCommand(TestLessInputStream.java:136)
> 2020-09-28T21:57:24.3007574Z  at 
> org.apache.maven.plugin.surefire.booterclient.lazytestprovider.AbstractCommandStream.read(AbstractCommandStream.java:100)
> 2020-09-28T21:57:24.3012904Z  at 
> org.apache.maven.surefire.shade.org.apache.maven.shared.utils.cli.StreamFeeder.feed(StreamFeeder.java:123)
> 2020-09-28T21:57:24.3014525Z  at 
> org.apache.maven.surefire.shade.org.apache.maven.shared.utils.cli.StreamFeeder.run(StreamFeeder.java:60)
> 2020-09-28T21:57:24.3015881Z 
> 2020-09-28T21:57:24.3017173Z "ThreadedStreamConsumer" #315 daemon prio=5 
> os_prio=0 tid=0x00007f130c01a800 nid=0x5590 waiting on condition 
> [0x00007f12e7798000]
> 2020-09-28T21:57:24.3019315Z    java.lang.Thread.State: WAITING (parking)
> 2020-09-28T21:57:24.3021382Z  at sun.misc.Unsafe.park(Native Method)
> 2020-09-28T21:57:24.3022314Z  - parking to wait for  <0x00000000def45660> (a 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
> 2020-09-28T21:57:24.3022827Z  at 
> java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> 2020-09-28T21:57:24.3023379Z  at 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
> 2020-09-28T21:57:24.3024066Z  at 
> java.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:403)
> 2020-09-28T21:57:24.3024632Z  at 
> org.apache.maven.plugin.surefire.booterclient.output.ThreadedStreamConsumer$Pumper.run(ThreadedStreamConsumer.java:83)
> 2020-09-28T21:57:24.3025279Z  at java.lang.Thread.run(Thread.java:748)
> 2020-09-28T21:57:24.3025479Z 
> 2020-09-28T21:57:24.3026200Z "surefire-fork-starter" #314 daemon prio=5 
> os_prio=0 tid=0x00007f12d17af800 nid=0x558f in Object.wait() 
> [0x00007f12e789c000]
> 2020-09-28T21:57:24.3026677Z    java.lang.Thread.State: WAITING (on object 
> monitor)
> 2020-09-28T21:57:24.3026990Z  at java.lang.Object.wait(Native Method)
> 2020-09-28T21:57:24.3027525Z  - waiting on <0x00000000def77e48> (a 
> java.lang.UNIXProcess)
> 2020-09-28T21:57:24.3027875Z  at java.lang.Object.wait(Object.java:502)
> 2020-09-28T21:57:24.3028358Z  at 
> java.lang.UNIXProcess.waitFor(UNIXProcess.java:395)
> 2020-09-28T21:57:24.3029123Z  - locked <0x00000000def77e48> (a 
> java.lang.UNIXProcess)
> 2020-09-28T21:57:24.3029639Z  at 
> org.apache.maven.surefire.shade.org.apache.maven.shared.utils.cli.CommandLineUtils$1.call(CommandLineUtils.java:260)
> 2020-09-28T21:57:24.3030222Z  at 
> org.apache.maven.plugin.surefire.booterclient.ForkStarter.fork(ForkStarter.java:614)
> 2020-09-28T21:57:24.3030775Z  at 
> org.apache.maven.plugin.surefire.booterclient.ForkStarter.access$600(ForkStarter.java:115)
> 2020-09-28T21:57:24.3031318Z  at 
> org.apache.maven.plugin.surefire.booterclient.ForkStarter$2.call(ForkStarter.java:444)
> 2020-09-28T21:57:24.3031840Z  at 
> org.apache.maven.plugin.surefire.booterclient.ForkStarter$2.call(ForkStarter.java:420)
> 2020-09-28T21:57:24.3032609Z  at 
> java.util.concurrent.FutureTask.run(FutureTask.java:266)
> 2020-09-28T21:57:24.3033081Z  at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> 2020-09-28T21:57:24.3033580Z  at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2020-09-28T21:57:24.3033994Z  at java.lang.Thread.run(Thread.java:748)
> 2020-09-28T21:57:24.3034191Z 
> 2020-09-28T21:57:24.3034882Z "ping-timer-10s" #312 daemon prio=5 os_prio=0 
> tid=0x00007f132e852000 nid=0x558e waiting on condition [0x00007f12e7697000]
> 2020-09-28T21:57:24.3035344Z    java.lang.Thread.State: TIMED_WAITING 
> (parking)
> 2020-09-28T21:57:24.3035645Z  at sun.misc.Unsafe.park(Native Method)
> 2020-09-28T21:57:24.3036329Z  - parking to wait for  <0x00000000de6d84d8> (a 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
> 2020-09-28T21:57:24.3036845Z  at 
> java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
> 2020-09-28T21:57:24.3037402Z  at 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)
> 2020-09-28T21:57:24.3038051Z  at 
> java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1093)
> 2020-09-28T21:57:24.3038675Z  at 
> java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)
> 2020-09-28T21:57:24.3039223Z  at 
> java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)
> 2020-09-28T21:57:24.3039721Z  at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)
> 2020-09-28T21:57:24.3040225Z  at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2020-09-28T21:57:24.3040629Z  at java.lang.Thread.run(Thread.java:748)
> 2020-09-28T21:57:24.3040840Z 
> 2020-09-28T21:57:24.3041480Z "timeout-check-timer" #311 daemon prio=5 
> os_prio=0 tid=0x00007f132e851000 nid=0x558d waiting on condition 
> [0x00007f12e6c1d000]
> 2020-09-28T21:57:24.3041950Z    java.lang.Thread.State: TIMED_WAITING 
> (parking)
> 2020-09-28T21:57:24.3042265Z  at sun.misc.Unsafe.park(Native Method)
> 2020-09-28T21:57:24.3042922Z  - parking to wait for  <0x00000000de6d8db8> (a 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
> 2020-09-28T21:57:24.3043442Z  at 
> java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
> 2020-09-28T21:57:24.3044008Z  at 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)
> 2020-09-28T21:57:24.3044639Z  at 
> java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1093)
> 2020-09-28T21:57:24.3045263Z  at 
> java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)
> 2020-09-28T21:57:24.3045942Z  at 
> java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)
> 2020-09-28T21:57:24.3046428Z  at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)
> 2020-09-28T21:57:24.3046930Z  at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2020-09-28T21:57:24.3047341Z  at java.lang.Thread.run(Thread.java:748)
> 2020-09-28T21:57:24.3047602Z 
> 2020-09-28T21:57:24.3047942Z "process reaper" #289 daemon prio=10 os_prio=0 
> tid=0x00007f12e001a000 nid=0x54b7 runnable [0x00007f12e705a000]
> 2020-09-28T21:57:24.3048333Z    java.lang.Thread.State: RUNNABLE
> 2020-09-28T21:57:24.3048666Z  at 
> java.lang.UNIXProcess.waitForProcessExit(Native Method)
> 2020-09-28T21:57:24.3049066Z  at 
> java.lang.UNIXProcess.lambda$initStreams$3(UNIXProcess.java:289)
> 2020-09-28T21:57:24.3049461Z  at 
> java.lang.UNIXProcess$$Lambda$7/59217951.run(Unknown Source)
> 2020-09-28T21:57:24.3049901Z  at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> 2020-09-28T21:57:24.3050408Z  at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2020-09-28T21:57:24.3050806Z  at java.lang.Thread.run(Thread.java:748)
> 2020-09-28T21:57:24.3051017Z 
> 2020-09-28T21:57:24.3051669Z "resolver-5" #16 daemon prio=5 os_prio=0 
> tid=0x00007f132df24800 nid=0x230 waiting on condition [0x00007f12e79b5000]
> 2020-09-28T21:57:24.3054788Z    java.lang.Thread.State: WAITING (parking)
> 2020-09-28T21:57:24.3055141Z  at sun.misc.Unsafe.park(Native Method)
> 2020-09-28T21:57:24.3055926Z  - parking to wait for  <0x0000000094fd64f0> (a 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
> 2020-09-28T21:57:24.3056437Z  at 
> java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> 2020-09-28T21:57:24.3056977Z  at 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
> 2020-09-28T21:57:24.3057552Z  at 
> java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
> 2020-09-28T21:57:24.3058045Z  at 
> java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)
> 2020-09-28T21:57:24.3058542Z  at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)
> 2020-09-28T21:57:24.3059031Z  at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2020-09-28T21:57:24.3059447Z  at java.lang.Thread.run(Thread.java:748)
> 2020-09-28T21:57:24.3059648Z 
> 2020-09-28T21:57:24.3060278Z "resolver-4" #15 daemon prio=5 os_prio=0 
> tid=0x00007f132df24000 nid=0x22f waiting on condition [0x00007f12e7cfd000]
> 2020-09-28T21:57:24.3060704Z    java.lang.Thread.State: WAITING (parking)
> 2020-09-28T21:57:24.3061011Z  at sun.misc.Unsafe.park(Native Method)
> 2020-09-28T21:57:24.3061728Z  - parking to wait for  <0x0000000094fd64f0> (a 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
> 2020-09-28T21:57:24.3062221Z  at 
> java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> 2020-09-28T21:57:24.3062780Z  at 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
> 2020-09-28T21:57:24.3063349Z  at 
> java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
> 2020-09-28T21:57:24.3063826Z  at 
> java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)
> 2020-09-28T21:57:24.3064326Z  at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)
> 2020-09-28T21:57:24.3064834Z  at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2020-09-28T21:57:24.3065235Z  at java.lang.Thread.run(Thread.java:748)
> 2020-09-28T21:57:24.3065444Z 
> 2020-09-28T21:57:24.3066063Z "resolver-3" #13 daemon prio=5 os_prio=0 
> tid=0x00007f132dc18000 nid=0x22d waiting on condition [0x00007f12e7dfe000]
> 2020-09-28T21:57:24.3066506Z    java.lang.Thread.State: WAITING (parking)
> 2020-09-28T21:57:24.3066811Z  at sun.misc.Unsafe.park(Native Method)
> 2020-09-28T21:57:24.3067648Z  - parking to wait for  <0x0000000094fd64f0> (a 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
> 2020-09-28T21:57:24.3068156Z  at 
> java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> 2020-09-28T21:57:24.3069049Z  at 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
> 2020-09-28T21:57:24.3069624Z  at 
> java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
> 2020-09-28T21:57:24.3070243Z  at 
> java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)
> 2020-09-28T21:57:24.3070744Z  at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)
> 2020-09-28T21:57:24.3071237Z  at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2020-09-28T21:57:24.3071652Z  at java.lang.Thread.run(Thread.java:748)
> 2020-09-28T21:57:24.3071850Z 
> 2020-09-28T21:57:24.3072543Z "resolver-2" #12 daemon prio=5 os_prio=0 
> tid=0x00007f132dac7000 nid=0x22c waiting on condition [0x00007f12f04e5000]
> 2020-09-28T21:57:24.3072997Z    java.lang.Thread.State: WAITING (parking)
> 2020-09-28T21:57:24.3073289Z  at sun.misc.Unsafe.park(Native Method)
> 2020-09-28T21:57:24.3073967Z  - parking to wait for  <0x0000000094fd64f0> (a 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
> 2020-09-28T21:57:24.3074477Z  at 
> java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> 2020-09-28T21:57:24.3075016Z  at 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
> 2020-09-28T21:57:24.3075591Z  at 
> java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
> 2020-09-28T21:57:24.3076083Z  at 
> java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)
> 2020-09-28T21:57:24.3076568Z  at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)
> 2020-09-28T21:57:24.3077069Z  at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2020-09-28T21:57:24.3077483Z  at java.lang.Thread.run(Thread.java:748)
> 2020-09-28T21:57:24.3077681Z 
> 2020-09-28T21:57:24.3078303Z "resolver-1" #11 daemon prio=5 os_prio=0 
> tid=0x00007f132dc04800 nid=0x22b waiting on condition [0x00007f12f05e6000]
> 2020-09-28T21:57:24.3078733Z    java.lang.Thread.State: WAITING (parking)
> 2020-09-28T21:57:24.3079039Z  at sun.misc.Unsafe.park(Native Method)
> 2020-09-28T21:57:24.3079710Z  - parking to wait for  <0x0000000094fd64f0> (a 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
> 2020-09-28T21:57:24.3080208Z  at 
> java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> 2020-09-28T21:57:24.3080757Z  at 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
> 2020-09-28T21:57:24.3081323Z  at 
> java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
> 2020-09-28T21:57:24.3081799Z  at 
> java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)
> 2020-09-28T21:57:24.3082300Z  at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)
> 2020-09-28T21:57:24.3082801Z  at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2020-09-28T21:57:24.3083200Z  at java.lang.Thread.run(Thread.java:748)
> 2020-09-28T21:57:24.3083410Z 
> 2020-09-28T21:57:24.3083732Z "Service Thread" #7 daemon prio=9 os_prio=0 
> tid=0x00007f132c0bc000 nid=0x227 runnable [0x0000000000000000]
> 2020-09-28T21:57:24.3084136Z    java.lang.Thread.State: RUNNABLE
> 2020-09-28T21:57:24.3084322Z 
> 2020-09-28T21:57:24.3084678Z "C1 CompilerThread1" #6 daemon prio=9 os_prio=0 
> tid=0x00007f132c0b9000 nid=0x226 waiting on condition [0x0000000000000000]
> 2020-09-28T21:57:24.3085104Z    java.lang.Thread.State: RUNNABLE
> 2020-09-28T21:57:24.3085287Z 
> 2020-09-28T21:57:24.3085639Z "C2 CompilerThread0" #5 daemon prio=9 os_prio=0 
> tid=0x00007f132c0b6000 nid=0x225 waiting on condition [0x0000000000000000]
> 2020-09-28T21:57:24.3086046Z    java.lang.Thread.State: RUNNABLE
> 2020-09-28T21:57:24.3086350Z 
> 2020-09-28T21:57:24.3086673Z "Signal Dispatcher" #4 daemon prio=9 os_prio=0 
> tid=0x00007f132c0b4800 nid=0x224 runnable [0x0000000000000000]
> 2020-09-28T21:57:24.3087079Z    java.lang.Thread.State: RUNNABLE
> 2020-09-28T21:57:24.3087258Z 
> 2020-09-28T21:57:24.3087594Z "Finalizer" #3 daemon prio=8 os_prio=0 
> tid=0x00007f132c084800 nid=0x223 in Object.wait() [0x00007f131c5f4000]
> 2020-09-28T21:57:24.3088033Z    java.lang.Thread.State: WAITING (on object 
> monitor)
> 2020-09-28T21:57:24.3088347Z  at java.lang.Object.wait(Native Method)
> 2020-09-28T21:57:24.3089023Z  - waiting on <0x00000000951fb148> (a 
> java.lang.ref.ReferenceQueue$Lock)
> 2020-09-28T21:57:24.3089446Z  at 
> java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:144)
> 2020-09-28T21:57:24.3090057Z  - locked <0x00000000951fb148> (a 
> java.lang.ref.ReferenceQueue$Lock)
> 2020-09-28T21:57:24.3090471Z  at 
> java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:165)
> 2020-09-28T21:57:24.3090890Z  at 
> java.lang.ref.Finalizer$FinalizerThread.run(Finalizer.java:216)
> 2020-09-28T21:57:24.3091164Z 
> 2020-09-28T21:57:24.3092959Z "Reference Handler" #2 daemon prio=10 os_prio=0 
> tid=0x00007f132c080000 nid=0x222 in Object.wait() [0x00007f131c6f5000]
> 2020-09-28T21:57:24.3094988Z    java.lang.Thread.State: WAITING (on object 
> monitor)
> 2020-09-28T21:57:24.3095317Z  at java.lang.Object.wait(Native Method)
> 2020-09-28T21:57:24.3095981Z  - waiting on <0x00000000951fb188> (a 
> java.lang.ref.Reference$Lock)
> 2020-09-28T21:57:24.3096349Z  at java.lang.Object.wait(Object.java:502)
> 2020-09-28T21:57:24.3096743Z  at 
> java.lang.ref.Reference.tryHandlePending(Reference.java:191)
> 2020-09-28T21:57:24.3097345Z  - locked <0x00000000951fb188> (a 
> java.lang.ref.Reference$Lock)
> 2020-09-28T21:57:24.3097756Z  at 
> java.lang.ref.Reference$ReferenceHandler.run(Reference.java:153)
> 2020-09-28T21:57:24.3098015Z 
> 2020-09-28T21:57:24.3098337Z "main" #1 prio=5 os_prio=0 
> tid=0x00007f132c00c800 nid=0x21e waiting on condition [0x00007f13351b9000]
> 2020-09-28T21:57:24.3098744Z    java.lang.Thread.State: WAITING (parking)
> 2020-09-28T21:57:24.3099042Z  at sun.misc.Unsafe.park(Native Method)
> 2020-09-28T21:57:24.3099626Z  - parking to wait for  <0x00000000dea8eb00> (a 
> java.util.concurrent.FutureTask)
> 2020-09-28T21:57:24.3100069Z  at 
> java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> 2020-09-28T21:57:24.3100498Z  at 
> java.util.concurrent.FutureTask.awaitDone(FutureTask.java:429)
> 2020-09-28T21:57:24.3100920Z  at 
> java.util.concurrent.FutureTask.get(FutureTask.java:191)
> 2020-09-28T21:57:24.3101412Z  at 
> org.apache.maven.plugin.surefire.booterclient.ForkStarter.awaitResultsDone(ForkStarter.java:476)
> 2020-09-28T21:57:24.3101997Z  at 
> org.apache.maven.plugin.surefire.booterclient.ForkStarter.runSuitesForkPerTestSet(ForkStarter.java:457)
> 2020-09-28T21:57:24.3102558Z  at 
> org.apache.maven.plugin.surefire.booterclient.ForkStarter.run(ForkStarter.java:298)
> 2020-09-28T21:57:24.3103084Z  at 
> org.apache.maven.plugin.surefire.booterclient.ForkStarter.run(ForkStarter.java:246)
> 2020-09-28T21:57:24.3103631Z  at 
> org.apache.maven.plugin.surefire.AbstractSurefireMojo.executeProvider(AbstractSurefireMojo.java:1183)
> 2020-09-28T21:57:24.3104266Z  at 
> org.apache.maven.plugin.surefire.AbstractSurefireMojo.executeAfterPreconditionsChecked(AbstractSurefireMojo.java:1011)
> 2020-09-28T21:57:24.3104884Z  at 
> org.apache.maven.plugin.surefire.AbstractSurefireMojo.execute(AbstractSurefireMojo.java:857)
> 2020-09-28T21:57:24.3105442Z  at 
> org.apache.maven.plugin.DefaultBuildPluginManager.executeMojo(DefaultBuildPluginManager.java:132)
> 2020-09-28T21:57:24.3105989Z  at 
> org.apache.maven.lifecycle.internal.MojoExecutor.execute(MojoExecutor.java:208)
> 2020-09-28T21:57:24.3106492Z  at 
> org.apache.maven.lifecycle.internal.MojoExecutor.execute(MojoExecutor.java:153)
> 2020-09-28T21:57:24.3106984Z  at 
> org.apache.maven.lifecycle.internal.MojoExecutor.execute(MojoExecutor.java:145)
> 2020-09-28T21:57:24.3107543Z  at 
> org.apache.maven.lifecycle.internal.LifecycleModuleBuilder.buildProject(LifecycleModuleBuilder.java:116)
> 2020-09-28T21:57:24.3108148Z  at 
> org.apache.maven.lifecycle.internal.LifecycleModuleBuilder.buildProject(LifecycleModuleBuilder.java:80)
> 2020-09-28T21:57:24.3109086Z  at 
> org.apache.maven.lifecycle.internal.builder.singlethreaded.SingleThreadedBuilder.build(SingleThreadedBuilder.java:51)
> 2020-09-28T21:57:24.3110696Z  at 
> org.apache.maven.lifecycle.internal.LifecycleStarter.execute(LifecycleStarter.java:120)
> 2020-09-28T21:57:24.3111201Z  at 
> org.apache.maven.DefaultMaven.doExecute(DefaultMaven.java:355)
> 2020-09-28T21:57:24.3111622Z  at 
> org.apache.maven.DefaultMaven.execute(DefaultMaven.java:155)
> 2020-09-28T21:57:24.3112176Z  at 
> org.apache.maven.cli.MavenCli.execute(MavenCli.java:584)
> 2020-09-28T21:57:24.3112582Z  at 
> org.apache.maven.cli.MavenCli.doMain(MavenCli.java:216)
> 2020-09-28T21:57:24.3112967Z  at 
> org.apache.maven.cli.MavenCli.main(MavenCli.java:160)
> 2020-09-28T21:57:24.3113351Z  at 
> sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 2020-09-28T21:57:24.3113783Z  at 
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> 2020-09-28T21:57:24.3114293Z  at 
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 2020-09-28T21:57:24.3114747Z  at 
> java.lang.reflect.Method.invoke(Method.java:498)
> 2020-09-28T21:57:24.3115196Z  at 
> org.codehaus.plexus.classworlds.launcher.Launcher.launchEnhanced(Launcher.java:289)
> 2020-09-28T21:57:24.3115685Z  at 
> org.codehaus.plexus.classworlds.launcher.Launcher.launch(Launcher.java:229)
> 2020-09-28T21:57:24.3116188Z  at 
> org.codehaus.plexus.classworlds.launcher.Launcher.mainWithExitCode(Launcher.java:415)
> 2020-09-28T21:57:24.3116695Z  at 
> org.codehaus.plexus.classworlds.launcher.Launcher.main(Launcher.java:356)
> 2020-09-28T21:57:24.3116964Z 
> 2020-09-28T21:57:24.3117226Z "VM Thread" os_prio=0 tid=0x00007f132c076000 
> nid=0x221 runnable 
> 2020-09-28T21:57:24.3117440Z 
> 2020-09-28T21:57:24.3117732Z "GC task thread#0 (ParallelGC)" os_prio=0 
> tid=0x00007f132c022000 nid=0x21f runnable 
> 2020-09-28T21:57:24.3117979Z 
> 2020-09-28T21:57:24.3118270Z "GC task thread#1 (ParallelGC)" os_prio=0 
> tid=0x00007f132c023800 nid=0x220 runnable 
> 2020-09-28T21:57:24.3118524Z 
> 2020-09-28T21:57:24.3118824Z "VM Periodic Task Thread" os_prio=0 
> tid=0x00007f132c0be800 nid=0x228 waiting on condition 
> 2020-09-28T21:57:24.3119083Z 
> 2020-09-28T21:57:24.3119286Z JNI global references: 853
> {code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to