[
https://issues.apache.org/jira/browse/FLINK-25373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Spongebob updated FLINK-25373:
------------------------------
Description:
I submit my Flinksql jobs to the Flink standalone cluster and what out of my
expectation is that TaskManagers could not free memory when all jobs are
finished whether normally or not.
And I found that there were many threads named like `
flink-taskexecutor-io-thread-x` and their states were waiting on conditions.
here's the detail of these threads:
"flink-taskexecutor-io-thread-31" Id=5386 WAITING on
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject@2da8b14c
at sun.misc.Unsafe.park(Native Method)
- waiting on
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject@2da8b14c
at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
at
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
!image-2021-12-19-11-48-33-622.png!
was:
I submit my Flinksql jobs to the Flink standalone cluster and what out of my
expectation is that TaskManagers could not free memory when all jobs are
finished whether normally or not.
And I found that there were many threads named like `
flink-taskexecutor-io-thread-x` and their states were waiting on conditions.
!image-2021-12-19-11-48-33-622.png!
> task manager can not free memory when jobs are finished
> -------------------------------------------------------
>
> Key: FLINK-25373
> URL: https://issues.apache.org/jira/browse/FLINK-25373
> Project: Flink
> Issue Type: Bug
> Components: API / Core
> Affects Versions: 1.14.0
> Environment: flink 1.14.0
> Reporter: Spongebob
> Priority: Major
> Attachments: image-2021-12-19-11-48-33-622.png
>
>
> I submit my Flinksql jobs to the Flink standalone cluster and what out of my
> expectation is that TaskManagers could not free memory when all jobs are
> finished whether normally or not.
> And I found that there were many threads named like `
> flink-taskexecutor-io-thread-x` and their states were waiting on conditions.
> here's the detail of these threads:
>
> "flink-taskexecutor-io-thread-31" Id=5386 WAITING on
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject@2da8b14c
> at sun.misc.Unsafe.park(Native Method)
> - waiting on
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject@2da8b14c
> at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> at
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
> at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
> at
> java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> at java.lang.Thread.run(Thread.java:748)
> !image-2021-12-19-11-48-33-622.png!
>
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
