[FLINK-33374] Execute REMOVE JAR command failed via SQL gateway

• Type: Improvement
• Status: Open
• Priority: Minor
• Resolution: Unresolved
• Affects Version/s: 1.18.0
• Component/s: Table SQL / Gateway
• Assignee: Unassigned
• Reporter: Xianxun Ye
• Created: 26/Oct/23 13:34
• Updated: 26/Oct/23 13:34

Description

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.

 

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] 

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