Flink taskmanager failed with StackOverflowError: null #2091
Description
Search before asking
- I searched in the issues and found nothing similar.
Fluss version
0.8.0 (latest release)
Please describe the bug 🐞
When close flink taskmanager of fluss sink, the below error will throw in some case:
at org.apache.fluss.shaded.netty4.i
2025-12-03 20:06:23,028 INFO org.apache.flink.runtime.taskmanager.Task [] - Attempting to fail task externally Source: log-table[15] -> LookupJoin[16] -> Calc[17] -> blackhole-sink[18]: Writer (67/200)#0 (59057ec382cb5111367df54c17e097d3_717c7b8afebbfb7137f6f0f99beb2a94_66_0).
2025-12-03 20:06:23,029 INFO org.apache.flink.runtime.taskmanager.Task [] - Task Source: log-table[15] -> LookupJoin[16] -> Calc[17] -> blackhole-sink[18]: Writer (67/200)#0 is already in state FAILED
2025-12-03 20:06:25,038 INFO org.apache.fluss.rpc.netty.client.NettyClient [] - Netty client was shutdown successfully.
2025-12-03 20:06:25,038 INFO org.apache.fluss.flink.source.lookup.FlinkAsyncLookupFunction [] - end close.
2025-12-03 20:06:25,055 INFO org.apache.flink.connector.base.source.reader.SourceReaderBase [] - Closing Source Reader.
2025-12-03 20:06:25,056 INFO org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher [] - Shutting down split fetcher 0
2025-12-03 20:06:25,058 INFO org.apache.fluss.client.table.scanner.log.RemoteLogDownloader$DownloadRemoteLogThread [] - Shutting down
2025-12-03 20:06:25,058 INFO org.apache.fluss.client.table.scanner.log.RemoteLogDownloader$DownloadRemoteLogThread [] - Stopped
2025-12-03 20:06:25,059 INFO org.apache.fluss.client.table.scanner.log.RemoteLogDownloader$DownloadRemoteLogThread [] - Shutdown completed
2025-12-03 20:06:25,066 INFO org.apache.fluss.client.table.scanner.log.LogFetcher [] - Fetcher for fluss.log-table is closed.
2025-12-03 20:06:25,066 INFO org.apache.fluss.client.token.DefaultSecurityTokenManager [] - Stopping security token renewal
2025-12-03 20:06:25,067 INFO org.apache.fluss.client.token.DefaultSecurityTokenManager [] - Stopped security token renewal
2025-12-03 20:06:27,077 INFO org.apache.fluss.rpc.netty.client.NettyClient [] - Netty client was shutdown successfully.
2025-12-03 20:06:27,091 INFO org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher [] - Split fetcher 0 exited.
2025-12-03 20:06:27,093 INFO org.apache.flink.runtime.taskmanager.Task [] - Freeing task resources for Source: log-table[15] -> LookupJoin[16] -> Calc[17] -> blackhole-sink[18]: Writer (67/200)#0 (59057ec382cb5111367df54c17e097d3_717c7b8afebbfb7137f6f0f99beb2a94_66_0).
2025-12-03 20:06:28,340 ERROR org.apache.flink.runtime.taskmanager.Task [] - FATAL - exception in resource cleanup of task Source: log-table[15] -> LookupJoin[16] -> Calc[17] -> blackhole-sink[18]: Writer (67/200)#0 (59057ec382cb5111367df54c17e097d3_717c7b8afebbfb7137f6f0f99beb2a94_66_0).
java.lang.StackOverflowError: null
at org.apache.flink.util.ExceptionUtils.stringifyException(ExceptionUtils.java:77) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.<init>(SerializedThrowable.java:81) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.<init>(SerializedThrowable.java:93) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.<init>(SerializedThrowable.java:62) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.addAllSuppressed(SerializedThrowable.java:150) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.<init>(SerializedThrowable.java:97) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.<init>(SerializedThrowable.java:93) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.<init>(SerializedThrowable.java:62) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.addAllSuppressed(SerializedThrowable.java:150) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.<init>(SerializedThrowable.java:97) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.<init>(SerializedThrowable.java:93) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.<init>(SerializedThrowable.java:62) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.addAllSuppressed(SerializedThrowable.java:150) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.<init>(SerializedThrowable.java:97) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.<init>(SerializedThrowable.java:93) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.<init>(SerializedThrowable.java:62) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.addAllSuppressed(SerializedThrowable.java:150) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.<init>(SerializedThrowable.java:97) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.<init>(SerializedThrowable.java:93) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.<init>(SerializedThrowable.java:62) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.addAllSuppressed(SerializedThrowable.java:150) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.<init>(SerializedThrowable.java:97) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.<init>(SerializedThrowable.java:93) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.<init>(SerializedThrowable.java:62) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.addAllSuppressed(SerializedThrowable.java:150) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.<init>(SerializedThrowable.java:97) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.<init>(SerializedThrowable.java:93) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.<init>(SerializedThrowable.java:62) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.addAllSuppressed(SerializedThrowable.java:150) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.<init>(SerializedThrowable.java:97) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.<init>(SerializedThrowable.java:93) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.<init>(SerializedThrowable.java:62) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.addAllSuppressed(SerializedThrowable.java:150) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.<init>(SerializedThrowable.java:97) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.<init>(SerializedThrowable.java:93) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.<init>(SerializedThrowable.java:62) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.addAllSuppressed(SerializedThrowable.java:150) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.<init>(SerializedThrowable.java:97) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.<init>(SerializedThrowable.java:93) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.<init>(SerializedThrowable.java:62) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.addAllSuppressed(SerializedThrowable.java:150) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.<init>(SerializedThrowable.java:97) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.<init>(SerializedThrowable.java:93) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.<init>(SerializedThrowable.java:62) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.addAllSuppressed(SerializedThrowable.java:150) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.<init>(SerializedThrowable.java:97) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.<init>(SerializedThrowable.java:93) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.<init>(SerializedThrowable.java:62) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.addAllSuppressed(SerializedThrowable.java:150) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.<init>(SerializedThrowable.java:97) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.<init>(SerializedThrowable.java:93) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.<init>(SerializedThrowable.java:62) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.addAllSuppressed(SerializedThrowable.java:150) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
at org.apache.flink.util.SerializedThrowable.<init>(SerializedThrowable.java:97) ~[flink-dist-1.20-vvr-11.2.1-jdk11.jar:1.20-vvr-11.2.1-jdk11]
Solution
No response
Are you willing to submit a PR?
- I'm willing to submit a PR!
Metadata
Metadata
Assignees
Labels
No labels