Xianxun Ye created FLINK-33374:
----------------------------------
Summary: Execute REMOVE JAR command failed via SQL gateway
Key: FLINK-33374
URL: https://issues.apache.org/jira/browse/FLINK-33374
Project: Flink
Issue Type: Improvement
Components: Table SQL / Gateway
Affects Versions: 1.18.0
Reporter: Xianxun Ye
Execute the below steps could reproduce the exception:
At first, I added a specified jar to the classloader via the ADD JAR command,
and using the SHOW JARS command also displayed the jars.
But the REMOVE JAR command is not supported right now.
{code:java}
Caused by: java.lang.UnsupportedOperationException: SQL Gateway doesn't support
REMOVE JAR syntax now.
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.callRemoveJar(OperationExecutor.java:550)
~[flink-sql-gateway-1.18.0.jar:1.18.0]
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.executeOperation(OperationExecutor.java:442)
~[flink-sql-gateway-1.18.0.jar:1.18.0]
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.executeStatement(OperationExecutor.java:207)
~[flink-sql-gateway-1.18.0.jar:1.18.0]
at
org.apache.flink.table.gateway.service.SqlGatewayServiceImpl.lambda$executeStatement$1(SqlGatewayServiceImpl.java:212)
~[flink-sql-gateway-1.18.0.jar:1.18.0]
at
org.apache.flink.table.gateway.service.operation.OperationManager.lambda$submitOperation$1(OperationManager.java:119)
~[flink-sql-gateway-1.18.0.jar:1.18.0] {code}
It seems the RemoveJarOperation is ignored.
https://github.com/apache/flink/blob/release-1.18.0/flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/operation/OperationExecutor.java#L550
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
