Jingqi Shi created FLINK-29653:
----------------------------------
Summary: 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
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)
