[
https://issues.apache.org/jira/browse/FLINK-29653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17644098#comment-17644098
]
Jingqi Shi commented on FLINK-29653:
------------------------------------
Hi, [~fsk119], [~luoyuxia], sorry to bother you, but i wonder is there any
progress on this issue?
Thank you very much.
> close DynamicResult but it was already closed
> ---------------------------------------------
>
> Key: FLINK-29653
> URL: https://issues.apache.org/jira/browse/FLINK-29653
> Project: Flink
> Issue Type: Bug
> Affects Versions: 1.15.0
> Reporter: Jingqi Shi
> Assignee: Jingqi Shi
> Priority: Major
> Labels: pull-request-available
>
> We have built a test environment with apache kyuubi and flink, and
> experienced a problem with LocalExecutor class.
>
> {code:java}
> 2022-09-08 22:53:37,729 WARN
> org.apache.kyuubi.engine.flink.operation.ExecuteStatement [] - Failed to
> clean result set 4515c4aa72d73cf368aba5ddabb675ce in session
> 681753c2-d945-4200-861c-6ad739e2a92c
> org.apache.flink.table.client.gateway.SqlExecutionException: Could not find a
> result with result identifier '4515c4aa72d73cf368aba5ddabb675ce'.
> at
> org.apache.flink.table.client.gateway.local.LocalExecutor.cancelQuery(LocalExecutor.java:306)
> ~[flink-sql-client-1.15.1-SNAPSHOT.jar:1.15.1-SNAPSHOT]
> at
> org.apache.kyuubi.engine.flink.operation.ExecuteStatement.cleanupQueryResult(ExecuteStatement.scala:180)
>
> [kyuubi-flink-sql-engine_2.12-1.5.1-incubating-SNAPSHOT.jar:1.5.1-incubating-SNAPSHOT]
> at
> org.apache.kyuubi.engine.flink.operation.ExecuteStatement.runQueryOperation(ExecuteStatement.scala:167)
>
> [kyuubi-flink-sql-engine_2.12-1.5.1-incubating-SNAPSHOT.jar:1.5.1-incubating-SNAPSHOT]
> at
> org.apache.kyuubi.engine.flink.operation.ExecuteStatement.org$apache$kyuubi$engine$flink$operation$ExecuteStatement$$executeStatement(ExecuteStatement.scala:111)
>
> [kyuubi-flink-sql-engine_2.12-1.5.1-incubating-SNAPSHOT.jar:1.5.1-incubating-SNAPSHOT]
> at
> org.apache.kyuubi.engine.flink.operation.ExecuteStatement$$anon$1.run(ExecuteStatement.scala:81)
>
> [kyuubi-flink-sql-engine_2.12-1.5.1-incubating-SNAPSHOT.jar:1.5.1-incubating-SNAPSHOT]
> at
> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
> [?:1.8.0_202]
> at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_202]
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> [?:1.8.0_202]
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> [?:1.8.0_202]
> at java.lang.Thread.run(Thread.java:748) [?:1.8.0_202] {code}
>
>
> ResultStore stores resultId and result, skips sessionId. But if one result
> reached closeSession(), all results in ResultStore will be closed.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
