swuferhong opened a new issue, #2091: URL: https://github.com/apache/fluss/issues/2091
### Search before asking - [x] I searched in the [issues](https://github.com/apache/fluss/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:25,068 INFO org.apache.fluss.rpc.netty.client.NettyClient [] - Connection2 to server 192.168.0.24:9123 (id: ts-2, rack: null) is closed. 2025-12-03 20:06:25,068 INFO org.apache.fluss.rpc.netty.client.NettyClient [] - Connection2 to server 192.168.0.26:9123 (id: ts-0, rack: null) is closed. 2025-12-03 20:06:25,069 INFO org.apache.fluss.rpc.netty.client.NettyClient [] - Connection2 to server 192.168.0.25:9123 (id: ts-1, rack: null) is closed. 2025-12-03 20:06:25,069 INFO org.apache.fluss.rpc.netty.client.NettyClient [] - Connection2 to server internal.svc.cluster.local.fluss-cn-tvn4jtqxm01:9123 (id: cs--1, rack: null) is closed. 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! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
