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:13:00 UTC
[jira] [Commented] (FLINK-29653) close DynamicResult but it was already closed
[ https://issues.apache.org/jira/browse/FLINK-29653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17618422#comment-17618422 ]
Jingqi Shi commented on FLINK-29653:
------------------------------------
Anyone can assign this to me?
> 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
> Priority: Major
>
> 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)