You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Jingqi Shi (Jira)" <ji...@apache.org> on 2022/10/17 05:10:00 UTC
[jira] [Created] (FLINK-29653) close DynamicResult but it was already closed
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)