[ https://issues.apache.org/jira/browse/FLINK-32219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17729879#comment-17729879 ]
Shengkai Fang commented on FLINK-32219: --------------------------------------- Merged into master: 83ba6b5348cbffb26e8d1d5ce6e8d6bb1994e3bc > SQL client hangs when executing EXECUTE PLAN > -------------------------------------------- > > Key: FLINK-32219 > URL: https://issues.apache.org/jira/browse/FLINK-32219 > Project: Flink > Issue Type: Bug > Components: Table SQL / Client > Affects Versions: 1.17.1 > Reporter: Shuai Xu > Assignee: Jane Chan > Priority: Major > Labels: pull-request-available > > I compiled a plan for an INSERT statement and executed the plan, but the SQL > client became unresponsive when executing the EXECUTE PLAN statement. I > confirmed that the Flink job is running normally by checking the Flink > dashboard. The only issue is that the SQL client becomes stuck and cannot > accept new commands. I printed the stack trace of the SQL client process, and > here is a part of it for reference. > {code:java} > "pool-2-thread-1" #30 prio=5 os_prio=31 tid=0x00000001172e5000 nid=0x6d03 > waiting on condition [0x0000000173e01000] > java.lang.Thread.State: WAITING (parking) > at sun.misc.Unsafe.park(Native Method) > - parking to wait for <0x000000076e72af20> (a > java.util.concurrent.CompletableFuture$Signaller) > at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) > at > java.util.concurrent.CompletableFuture$Signaller.block(CompletableFuture.java:1707) > at > java.util.concurrent.ForkJoinPool.managedBlock(ForkJoinPool.java:3323) > at > java.util.concurrent.CompletableFuture.waitingGet(CompletableFuture.java:1742) > at > java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908) > at > org.apache.flink.table.api.internal.InsertResultProvider.hasNext(InsertResultProvider.java:83) > at > org.apache.flink.table.api.internal.InsertResultProvider.access$200(InsertResultProvider.java:37) > at > org.apache.flink.table.api.internal.InsertResultProvider$Iterator.hasNext(InsertResultProvider.java:106) > at java.util.Iterator.forEachRemaining(Iterator.java:115) > at > org.apache.flink.util.CollectionUtil.iteratorToList(CollectionUtil.java:115) > at > org.apache.flink.table.gateway.service.result.ResultFetcher.fromTableResult(ResultFetcher.java:163) > at > org.apache.flink.table.gateway.service.operation.OperationExecutor.callOperation(OperationExecutor.java:542) > at > org.apache.flink.table.gateway.service.operation.OperationExecutor.executeOperation(OperationExecutor.java:440) > at > org.apache.flink.table.gateway.service.operation.OperationExecutor.executeStatement(OperationExecutor.java:195) > at > org.apache.flink.table.gateway.service.SqlGatewayServiceImpl.lambda$executeStatement$1(SqlGatewayServiceImpl.java:212) > at > org.apache.flink.table.gateway.service.SqlGatewayServiceImpl$$Lambda$389/1391083077.apply(Unknown > Source) > at > org.apache.flink.table.gateway.service.operation.OperationManager.lambda$submitOperation$1(OperationManager.java:119) > at > org.apache.flink.table.gateway.service.operation.OperationManager$$Lambda$390/208625838.call(Unknown > Source) > at > org.apache.flink.table.gateway.service.operation.OperationManager$Operation.lambda$run$0(OperationManager.java:258) > at > org.apache.flink.table.gateway.service.operation.OperationManager$Operation$$Lambda$392/670621032.run(Unknown > Source) > at > java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) > at java.util.concurrent.FutureTask.run(FutureTask.java:266) > at > java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) > at java.util.concurrent.FutureTask.run(FutureTask.java:266) > at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) > at java.lang.Thread.run(Thread.java:750) > {code} -- This message was sent by Atlassian Jira (v8.20.10#820010)